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

Prefect tasks not responding to timeout_seconds #188

Open
tjgalvin opened this issue Nov 12, 2024 · 0 comments
Open

Prefect tasks not responding to timeout_seconds #188

tjgalvin opened this issue Nov 12, 2024 · 0 comments

Comments

@tjgalvin
Copy link
Owner

This is related to a separate issue described in #187

I have tried to uses prefects timeout_seconds functionality exposed as part of the task decorator. My hope was that if the bane error was tripped, prefect would kill and relaunch. The specifics:

# BANE sometimes gets cauht in some stalled staTE
@task(timeout_seconds=60 * 45, retries=3)
def task_run_bane_and_aegean(
    image: Union[WSCleanCommand, LinmosCommand], aegean_container: Path
) -> AegeanOutputs:

My understanding of this is that after 45 minutes the task will be cancelled, moved to the failed state, and then rescheduled. However it seems like this is not being respected. Will need to mock up something to test with. Potential issues are around:

  • dask task runner
  • slurm queue
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

No branches or pull requests

1 participant