paramecio/pastafari2
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity

Added support for rq using redis

Browse source
This commit is contained in:
absurdo 2023-09-12 00:15:08 +02:00
parent 0c149683ff
commit d73ac7e66a
1 changed files with 7 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

12
models/tasks.py
View file

@ -204,7 +204,7 @@ class Task(WebModel):
return False return False
""" """
#q = Queue(connection=Redis()) q = Queue(connection=Redis())
if yes_parent: if yes_parent:
arr_task=self.select_a_row(task_id) arr_task=self.select_a_row(task_id)
@ -225,21 +225,23 @@ class Task(WebModel):
final_sql=sql_insert+", ".join(sql_insert_values) final_sql=sql_insert+", ".join(sql_insert_values)
self.query(final_sql) self.query(final_sql)
"""
with self.query('select id from task WHERE parent_id=%s', [task_id]) as cursor: with self.query('select id from task WHERE parent_id=%s', [task_id]) as cursor:
for row in cursor: for row in cursor:
#print(row) #print(row)
result = q.enqueue(task, row['id'], job_timeout=3600) 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) #result = q.enqueue(task, task_id, job_timeout=3600)
return True 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): def send_task_to_server(self):