Skip to content

Instantly share code, notes, and snippets.

@anna-geller
Created November 7, 2022 04:40
Show Gist options
  • Save anna-geller/9994b4b82fd6fd1121ac3848ed69044d to your computer and use it in GitHub Desktop.
Save anna-geller/9994b4b82fd6fd1121ac3848ed69044d to your computer and use it in GitHub Desktop.
from datetime import date
from prefect import flow
from prefect.deployments import run_deployment
@flow
def parent(
start_date: date = date(2022, 11, 1), # parametrized for backfills
end_date: date = date.today(),
deployment_name: str = "local-process",
):
params = dict(start_date=start_date, end_date=end_date)
run_deployment(
name=f"raw-data-jaffle-shop/{deployment_name}",
flow_run_name="raw-data-shop",
parameters=params,
)
run_deployment(
name=f"raw-data-marketing/{deployment_name}",
flow_run_name="raw-data-marketing",
parameters=params,
)
run_deployment(name=f"dbt-jaffle-shop/{deployment_name}", flow_run_name="shop")
run_deployment(
name=f"dbt-attribution/{deployment_name}", flow_run_name="attribution"
)
run_deployment(name=f"dashboards/{deployment_name}", flow_run_name="dashboards")
run_deployment(name=f"sales-forecast/{deployment_name}", flow_run_name="forecast")
if __name__ == "__main__":
parent()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment