|
@@ -34,7 +34,7 @@ def get_new_workers(**kwargs):
|
|
if 'ti' not in kwargs:
|
|
if 'ti' not in kwargs:
|
|
raise ValueError('ti not present in kwargs')
|
|
raise ValueError('ti not present in kwargs')
|
|
ti = kwargs.get('ti')
|
|
ti = kwargs.get('ti')
|
|
- active_tasks = ti.xcom_pull(task_ids='qstat_on_remote')
|
|
|
|
|
|
+ active_tasks = ti.xcom_pull(task_ids='fetch_active_jobs_from_hpc')
|
|
active_tasks = active_tasks.decode()
|
|
active_tasks = active_tasks.decode()
|
|
active_tasks = json.loads(active_tasks)
|
|
active_tasks = json.loads(active_tasks)
|
|
queued_tasks = ti.xcom_pull(task_ids='fetch_queue_list_from_redis')
|
|
queued_tasks = ti.xcom_pull(task_ids='fetch_queue_list_from_redis')
|