Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Enqueue dependents when job is abandoned and moved to FailedJobRegistry #2008

Open
wants to merge 1 commit into
base: master
Choose a base branch
from

Conversation

Marishka17
Copy link

This PR fixes the issue #2006

Copy link

codecov bot commented Nov 26, 2023

Codecov Report

All modified and coverable lines are covered by tests ✅

Comparison is base (d11094a) 93.84% compared to head (5b3484d) 93.84%.

Additional details and impacted files
@@           Coverage Diff           @@
##           master    #2008   +/-   ##
=======================================
  Coverage   93.84%   93.84%           
=======================================
  Files          29       29           
  Lines        3897     3898    +1     
=======================================
+ Hits         3657     3658    +1     
  Misses        240      240           

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

@@ -270,6 +270,7 @@ def cleanup(self, timestamp: Optional[float] = None):
job.save(pipeline=pipeline, include_meta=False)
job.cleanup(ttl=-1, pipeline=pipeline)
failed_job_registry.add(job, job.failure_ttl)
queue.enqueue_dependents(job)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

You'll need to check whether the parent job has allow_failure=True. Please add a test case for this as well.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants