Skip to main content

Macros

Conveyor provides several custom Airflow macros to simplify certain patterns.

macros.conveyor.env()​

returns the name of the current environment. You can use this to customize your DAG based on the environment you are in.

macros.conveyor.project()​

returns the name of the current project. You can use this to inject the name of the project in operators shared across projects.

macros.conveyor.image('X')​

returns a path to the image of project X that is deployed to the current environment.

info

By default, the Operator provided by Airflow will use the image of the project the dag belongs to. So this is only needed when you want to run the image of a different project.