Cast ENV maxJobs to int to compute max_jobs_to_take (#84)

oceanprotocol · Oct 4, 2023 · 5d562ca · 5d562ca
1 parent b530521
commit 5d562ca
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/operator_engine/operator_main.py b/operator_engine/operator_main.py
@@ -225,7 +225,7 @@ def run_events_monitor():
             "storageExpiry": OperatorConfig.ENVIROMENT_storageExpiry,
             "maxJobDuration": OperatorConfig.ENVIROMENT_maxJobDuration,
         }
-        max_jobs_to_take = OperatorConfig.ENVIROMENT_maxJobs - current_jobs
+        max_jobs_to_take = int(OperatorConfig.ENVIROMENT_maxJobs) - current_jobs
         jobs = announce_and_get_sql_pending_jobs(logger, announce, max_jobs_to_take)
         for job in jobs:
             logger.info(f"Starting handler for job {job}")