Verified Commit f71721e3 authored by Peter Stanko's avatar Peter Stanko
Browse files

Submission scheduled for set in the async task

parent 9f788fec
Pipeline #20588 passed with stage
in 10 minutes and 3 seconds
......@@ -62,6 +62,8 @@ class SubmissionProcessor:
delay = self.get_delay_for_submission()
args = (self.submission.id, self.params)
from .tasks import start_processing_submission
self.submission.scheduled_for = delay
self._rest.general.write_entity(self.submission)
start_processing_submission.apply_async(args=args, countdown=delay)
def submission_store_ended(self, version: str):
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment