Khuyen Tran
09/08/2022, 7:02 PMAlix Cook
09/08/2022, 11:02 PMAnna Geller
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
Anna Geller
Benjamin Cerigo
09/21/2022, 12:37 PMRich Tata
09/22/2022, 1:21 AMAnna Geller
badasstronaut
09/29/2022, 6:51 PMprefect-aws
and prefect-dask
+ dask-cloudprovider
for autoscalingDaniel Conway
10/06/2022, 6:57 PMAnna Geller
run_deployment
utility was driven, a.o., by his feedback in the Community and -- the timestamp in the video shows the reason why Oscar implemented his own way of running flows from deployment, and the final implementation in Prefect 2.5 even used the same name as the one implemented by Oscar! ๐
Great work, and really glad to have you in the community! ๐Anna Geller
Khuyen 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.Zanie
Kalise Richmond
10/19/2022, 7:03 PMJeff Hale
10/19/2022, 7:39 PMRyan 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