From d73ac7e66abe0f44703d1fc03ae732fcad4cd266 Mon Sep 17 00:00:00 2001 From: absurdo Date: Tue, 12 Sep 2023 00:15:08 +0200 Subject: [PATCH] Added support for rq using redis --- models/tasks.py | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/models/tasks.py b/models/tasks.py index 21f976e..71d4222 100644 --- a/models/tasks.py +++ b/models/tasks.py @@ -204,7 +204,7 @@ class Task(WebModel): return False """ - #q = Queue(connection=Redis()) + q = Queue(connection=Redis()) if yes_parent: arr_task=self.select_a_row(task_id) @@ -225,21 +225,23 @@ class Task(WebModel): final_sql=sql_insert+", ".join(sql_insert_values) self.query(final_sql) - """ + with self.query('select id from task WHERE parent_id=%s', [task_id]) as cursor: for row in cursor: #print(row) result = q.enqueue(task, row['id'], job_timeout=3600) - """ + else: - return self.send_task_to_server() + result = q.enqueue(task, task_id, job_timeout=3600) + + #return self.send_task_to_server() #result = q.enqueue(task, task_id, job_timeout=3600) return True - # Function for send task to task server + # Function for send task to task server if not using rq worker def send_task_to_server(self):