Khuyen Tran
09/08/2022, 7:02 PMAlix Cook
09/08/2022, 11:02 PMAnna Geller
09/14/2022, 8:30 PMwatch the recording▾
Saurabh Indoria
09/15/2022, 4:21 AMBianca Hoch
09/15/2022, 9:23 PMErik
09/17/2022, 10:52 PMslack webhook
for block/notifications in the prefect ui.
If you haven’t used google chat webhooks, it’s even slightly easier than slack. https://developers.google.com/chat/how-tos/webhooks#create_a_webhookAnna Geller
09/19/2022, 12:31 PMAnna Geller
09/20/2022, 9:17 AMBenjamin Cerigo
09/21/2022, 12:37 PMRich Tata
09/22/2022, 1:21 AMAnna Geller
09/27/2022, 3:24 PMbadasstronaut
09/29/2022, 6:51 PMprefect-aws
and prefect-dask
+ dask-cloudprovider
for autoscalingDaniel Conway
10/06/2022, 6:57 PMAnna Geller
10/07/2022, 10:53 AMrun_deployment
utility was driven, a.o., by his feedback in the Community and this live stream▾
Anna Geller
10/11/2022, 11:09 AMKhuyen Tran
10/14/2022, 2:14 PMHenning Holgersen
10/16/2022, 2:02 PMDeployment
class), in separate files that imports the flow and creates+applies a deployment. These files have a common naming pattern, all ending with .deployment.py
, so that github action can pick them up and run them. This way, the flow file itself remains clean, and we don’t hardcode any config in the github action yaml, making it fully configurable.
Thanks to @Emil Christensen for explaining the point of deployments to me in a way I finally understood.
Oh, and there is also a cookiecutter template to create a new skeleton flow.Michael Adkins
10/19/2022, 4:57 PMKalise Richmond
10/19/2022, 7:03 PMJeff Hale
10/19/2022, 7:39 PMChris Reuter
10/20/2022, 1:38 PMhttps://youtu.be/ZK1s8OfVSpY▾
Ryan Peden
10/21/2022, 4:11 AMFrancesco Bartoli
10/27/2022, 10:39 AMKhuyen Tran
10/31/2022, 3:11 PMfrom prefect import flow, task
from prefect.blocks.notifications import SlackWebhook
from prefect_alert import alert_on_failure
@task
def may_fail():
raise ValueError()
@alert_on_failure(block_type=SlackWebhook, block_name="test")
@flow
def failed_flow():
res = may_fail()
return res
if __name__=="__main__":
failed_flow()
Thanks @Ryan Peden for contributing the collection!Khuyen Tran
11/01/2022, 4:12 PMRyan Peden
11/03/2022, 2:49 PMBen Muller
11/09/2022, 10:05 PMCarlo
11/10/2022, 2:53 PMStéphan Taljaard
11/16/2022, 9:19 AMfrom typing import Literal
from prefect import flow
AllowedStrings = Literal["A", "B"]
@flow
def example(str_input: AllowedStrings):
print(str_input)
example("C")
--->
11:15:58.598 | INFO | prefect.engine - Created flow run 'blond-auk' for flow 'example'
11:15:58.598 | ERROR | Flow run 'blond-auk' - Validation of flow parameters failed with error: ParameterTypeError: Flow run received invalid parameters:
- str_input: unexpected value; permitted: 'A', 'B'
Anna Geller
11/16/2022, 1:05 PMAnna Geller
11/16/2022, 1:05 PMChris Reuter
11/16/2022, 2:20 PM