Skip to content

Commit d35557a

Browse files
reverted local setup change
1 parent 61bf42d commit d35557a

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

tasks/task_runners.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -81,13 +81,13 @@ def run_task(self, job_uid=None, user=None, ondemand=True): # noqa
8181
LOG.debug('Saved task: {0}'.format(format_name))
8282

8383
if ondemand:
84-
run_task_remote(run_uid)
85-
db.close_old_connections()
86-
# run_task_async_ondemand.send(run_uid)
84+
# run_task_remote(run_uid)
85+
# db.close_old_connections()
86+
run_task_async_ondemand.send(run_uid)
8787
else:
88-
run_task_remote(run_uid)
89-
db.close_old_connections()
90-
# run_task_async_scheduled.send(run_uid)
88+
# run_task_remote(run_uid)
89+
# db.close_old_connections()
90+
run_task_async_scheduled.send(run_uid)
9191
return run
9292

9393
@dramatiq.actor(max_retries=0,queue_name='default',time_limit=1000*60*60*6)

0 commit comments

Comments
 (0)