Fixup to timeout

Author: kfindeisen

python/activator/activator.py

@@ -61,7 +61,7 @@
 # The skymap to use in the central repo
 skymap = os.environ["SKYMAP"]
 # The maximum time to spend on a single visit.
-global_timeout = os.environ.get("WORKER_TIMEOUT", None)
+global_timeout = float(os.environ.get("WORKER_TIMEOUT", 0.0))
 # URI to the main repository to contain processing results
 write_repo = os.environ["CENTRAL_REPO"]
 # URI to the main repository containing calibs and templates
@@ -537,14 +537,17 @@ async def _manage_process_visit(expected_visit: FannedOutVisit):
     This function encapsulates the use of asyncio by process_visit, while
     delegating all actual processing to `_process_visit_or_cancel`.
     """
-    try:
-        async with asyncio.timeout(global_timeout):  # No timeout if None
-            await _process_visit_or_cancel(expected_visit)
-    except TimeoutError:
-        _log.error(f"Processing of group {expected_visit.group} detector {expected_visit.detector} "
-                   f"failed to complete in {global_timeout} s. "
-                   "Outputs have *NOT* been written.")
-        raise
+    if global_timeout > 0.0:
+        try:
+            async with asyncio.timeout(global_timeout):
+                await _process_visit_or_cancel(expected_visit)
+        except TimeoutError:
+            _log.error(f"Processing of group {expected_visit.group} detector {expected_visit.detector} "
+                       f"failed to complete in {global_timeout} s. "
+                       "Outputs have *NOT* been written.")
+            raise
+    else:
+        await _process_visit_or_cancel(expected_visit)
 
 
 async def _process_visit_or_cancel(expected_visit: FannedOutVisit):