Luigi-swf

Latest version: v0.14.1

Safety actively analyzes 621420 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 1 of 2

0.14.1

swf_wf_run_id` is now saved on task instances in activity task workers (for `run()`, `complete()`, `output()`, etc.) and decider workers (for `requires()`). This can be used when saving state scoped to the workflow execution. For example, you might use it as part of an output directory when the data segment being operated on is a function of the start time of the first task in the workflow, e.g. the latest checkpoint in a queue, as opposed to being a function of the Luigi parameter values.

In order to keep your workflows compatible with the regular Luigi scheduler, you might access the value this way and have a backup strategy for when it's missing:

python
def run(self):
run_id = getattr(self, 'swf_wf_run_id', None)
. . .

0.13.4

The swf_wf_start_to_close_timeout field on workflow tasks is no longer required and defaults to 1 year (`'NONE'` is not valid in the SWF API).

This also includes a refactor of the decider.

0.13.3

The `swf_wf_start_to_close_timeout` field on workflow tasks is no longer required and defaults to `'NONE'`. (Note: please use 0.13.4, as 'NONE' is not valid).

0.13.1

Example fix

0.13.0

0.12.5

New `swf_running_mutex` property on tasks. Set this to a string indicating the name of a mutex to enforce one-at-a-time scheduling per workflow execution. Also removes dependency on arrow.

Page 1 of 2

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.