New done validation of the future, avoids possible errors with double…

… callback calling
hivesolutions · Mar 14, 2019 · 1d2a0df · 1d2a0df
1 parent 8eeee52
commit 1d2a0df
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/appier/async_old.py b/src/appier/async_old.py
@@ -231,6 +231,11 @@ def to_coroutine(callable, *args, **kwargs):
     callback = kwargs.get("callback", None)
 
     def callback_wrap(result, *args, **kwargs):
+        # in case the future is already done there's
+        # nothing remaining to be done returns immediately
+        # the callback as not result remain to be set
+        if future.done(): return
+
         # sets the final result in the associated future
         # this should contain the contents coming from
         # the callback operation (payload)