Fix: invalidate cache before status check

remove duplicate args for run_connector
intelowlproject · Jul 12, 2021 · 8aad3c2 · 8aad3c2
1 parent 1f9cd48
commit 8aad3c2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/api_app/connectors_manager/controller.py b/api_app/connectors_manager/controller.py
@@ -91,14 +91,14 @@ def start_connectors(
         celery_app.send_task(
             CELERY_TASK_NAME,
             args=args,
-            kwargs={"job_id": job_id, "runtime_conf": runtime_conf, **celery_kwargs},
+            kwargs={"runtime_conf": runtime_conf, **celery_kwargs},
             queue=queue,
             soft_time_limit=stl,
             task_id=task_id,
         )
 
     # cache the task ids
-    cache.set(build_cache_key(job_id), connectors_task_id_map.values())
+    cache.set(build_cache_key(job_id), list(connectors_task_id_map.values()))
 
     return connectors_task_id_map
 

diff --git a/intel_owl/tasks.py b/intel_owl/tasks.py
@@ -71,7 +71,9 @@ def run_analyzer(job_id: int, config_dict: dict, **kwargs):
     # run analyzer
     instance = analyzers_controller.run_analyzer(job_id, config_dict, **kwargs)
     # fire connectors when job finishes with success
-    if instance and instance._job.status == "reported_without_fails":
+    if instance and instance._job:
+        del instance._job  # invalidate cache
+    if instance._job.status == "reported_without_fails":
         app.send_task(
             "on_job_success",
             args=[