Sarah Floris
03/10/2022, 6:49 PMAnna Geller
Sarah Floris
03/10/2022, 6:52 PMAnna Geller
Sarah Floris
03/10/2022, 6:55 PMextract_Twilio = ExtractTwilio()
transform_Twilio = TransformTwilio()
load_Twilio = LoadTwilio()
with Flow(name="TwilioFlow", run_config=UniversalRun(labels=['somethingawesome'])) as flow:
extracted_Twilio = extract_Twilio(TWILIO_ACCOUNT_SID, TWILIO_AUTH_TOKEN)
transformed_Twilio = transform_Twilio(extracted_Twilio['results'])
loaded_Twilio = load_Twilio(transformed_Twilio)
if __name__ == "__main__":
if ENVIRONMENT == 'local':
registered_flow_id = flow.register(project_name="Development")
client.create_flow_run(flow_id=registered_flow_id)
Anna Geller
Sarah Floris
03/10/2022, 6:56 PMAnna Geller
with Flow(name="TwilioFlow",
storage== GitHub(
repo="yourgithub_account/your_repo_name",
path=f"flows/{FLOW_NAME}.py", # just example
access_token_secret="GITHUB_ACCESS_TOKEN",
),
run_config==KubernetesRun(
image="<http://YOUR_ACR_REGISTRY.azurecr.io/examplepath/flows|YOUR_ACR_REGISTRY.azurecr.io/examplepath/flows>",
labels=["aks"], # just example agent label
image_pull_secrets=["aks"], # see README
),
) as flow:
Sarah Floris
03/10/2022, 7:05 PMAnna Geller
Sarah Floris
03/10/2022, 7:07 PMAnna Geller
Sarah Floris
03/10/2022, 7:07 PMAnna Geller
Sarah Floris
03/10/2022, 7:08 PMAnna Geller
prefect run --name yourflowname --project XXX --watch
Sarah Floris
03/10/2022, 7:24 PMAnna Geller
Sarah Floris
03/11/2022, 3:06 PMAnna Geller