Pierre Monico
11/09/2022, 9:41 AMThomas Pedersen
11/09/2022, 10:05 AMDan Wise
11/09/2022, 11:48 AMToshali Narula
11/09/2022, 2:20 PMRevanth
11/09/2022, 2:33 PMVadym Dytyniak
11/09/2022, 3:09 PMKhuyen Tran
11/09/2022, 4:59 PMAlexandru Anghel
11/09/2022, 5:33 PMfrom tasks.date import get_start_date
@task(name='Generate start date', retries=2, retry_delay_seconds=10)(get_start_date)
It fails with `RuntimeError: Tasks cannot be run outside of a flow. To call the underlying task function outside of a flow use task.fn()
.`
Thanks!Kingsley
11/09/2022, 7:22 PMTim Enders
11/09/2022, 7:40 PMMadison Schott
11/09/2022, 10:07 PMScott McCallen
11/09/2022, 10:25 PMTim Ricablanca
11/09/2022, 11:55 PMRunning
states but not for Failed
ā details in thread:Kishan
11/10/2022, 2:44 AMKishan
11/10/2022, 2:47 AMmerlin
11/10/2022, 4:46 AMValueError
to trigger a failure, and thats how to manage the state of subsequent tasks or flows.
Here's the thing: I don't want to see a stack trace unless it is some new failure that I need to troubleshoot. For the expected exceptions I want to post an error the log and proceed with my flow according to logic I design.
I'm having trouble returning a manual state of Cancelled, concrete example and logs posted in thread. Can anyone guide me toward causing the entire flow to be cancelled without raising an exception?Rohith
11/10/2022, 9:56 AMredsquare
11/10/2022, 10:01 AMDan Wise
11/10/2022, 11:18 AMMiremad Aghili
11/10/2022, 2:26 PMVadym Dytyniak
11/10/2022, 3:01 PMEvgeny Ivanov
11/10/2022, 3:34 PMThen, register to view the block on Prefect Cloud:
But there is no moduleCopy codeprefect block register -m prefect_dask.credentials
credentials
in prefect_dask
. And I get the following error (not a surpirse):
```Unable to load prefect_dask.credentials. Please make sure the module is installed in your current
environment.```I wonder if this module has ever existed? Or maybe there are plans to create it?
Arthur Jacquemart
11/10/2022, 3:51 PMDavid Beck
11/10/2022, 4:39 PMKalise Richmond
11/10/2022, 6:00 PMPatrick Tan
11/10/2022, 6:51 PMBoggdan Barrientos
11/10/2022, 7:37 PMAshley Felber
11/10/2022, 10:23 PMprefect deployment build -n prod -q prod -a
-ib ecs-task/prod -sb s3/prod flow_script.py:flow_function_name
Tim Ricablanca
11/10/2022, 10:24 PMprefect-orion-1 | 21:53:34.590 | DEBUG | prefect.orion.services.flowrunnotifications - Got 3 notifications from queue.
However, it looks like the code intends for only one notification to be read off the queue in the first place: https://github.com/PrefectHQ/prefect/blob/main/src/prefect/orion/services/flow_run_notifications.py#L38-L42.Karlo
11/10/2022, 10:40 PM