Merge branch 'main' of github.com:amusecode/amuse

src/amuse/rfi/async_request.py

@@ -58,8 +58,8 @@ def get_mpi_request(self):
     def get_socket(self):
         raise Exception("not implemented")
 
-    #~ def is_pool(self):
-        #~ return False
+    # def is_pool(self):
+        # return False
 
     def join(self, other):
         if other is None:
@@ -82,8 +82,8 @@ def waits_for(self):
     def __getitem__(self, index):
         return IndexedASyncRequest(self,index)
 
-    #~ def __getattr__(self, name):
-        #~ print name, "<<"
+    # def __getattr__(self, name):
+        # print name, "<<"
 
     def __add__(self, other):
         return baseOperatorASyncRequest(self,other, operator.add)
@@ -127,8 +127,8 @@ def __iter__(self):
         else:
             yield self
 
-    #~ def __call__(self):
-        #~ return self.result()
+    # def __call__(self):
+        # return self.result()
 
 class DependentASyncRequest(AbstractASyncRequest):
     def __init__(self, parent, request_factory):
@@ -183,12 +183,12 @@ def is_result_available(self):
             if self.request is None:
                 return False
 
-        #~ if not self.parent.is_finished:
-            #~ return False
+        # if not self.parent.is_finished:
+            # return False
 
         if self.request is None:
             return False
-            #~ raise Exception("something went wrong (exception of parent?)")
+            # raise Exception("something went wrong (exception of parent?)")
 
         return self.request.is_result_available()
 
@@ -607,7 +607,7 @@ def add_request(self, async_request, result_handler = None, args=(), kwargs={}):
             return
         if async_request in self.registered_requests:
             return
-            #~ raise Exception("Request is already registered, cannot register a request more than once")
+            # raise Exception("Request is already registered, cannot register a request more than once")
 
         self.registered_requests.add(async_request)