Skip to content

Commit 25f5a2a

Browse files
committed
Don't go adding more files if the request is terminated
1 parent 405ae91 commit 25f5a2a

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

servicex_app/servicex_app/lookup_result_processor.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,11 @@ def celery_task_name(request_id):
4242
def add_files_to_processing_queue(self, request, files=None):
4343
if files is None:
4444
files = request.all_files
45+
if request.status.is_complete:
46+
current_app.logger.debug("Rejecting file addition request, request is canceled",
47+
extra={
48+
"task_id": self.celery_task_name(request.request_id)})
49+
return
4550
for file_record in files:
4651
self.celery.send_task("transformer_sidecar.transform_file",
4752
kwargs={

0 commit comments

Comments
 (0)