Category "airflow"

airflow kubernetes default setup ERROR: relation "log" does not exist at character 13

I deployed the default helm chart for airflow 2. The postgres pod is reporting an error: ERROR: relation "log" does not exist at character 13 This appears af

Only works with the CeleryExecutor

I am new at airflow and when i click run 'ignore all dependence' on Task Instance Context Menu like this: Task Instance Context Menu It leads to 'Only works

Airflow: Trigger DAG via UI with Parameters/Config

I see that one can trigger_dag with parameters/config key-value pairs using the airflow command line: For Apache Airflow, How can I pass the parameters when ma

Managing DBT profile file in MWAA

I would like to use DBT in MWAA Airflow enviroment. To achieve this I need to install DBT in the managed environment and from there run the dbt commands via the

Proper way to create dynamic workflows in Airflow

Problem Is there any way in Airflow to create a workflow such that the number of tasks B.* is unknown until completion of Task A? I have looked at subdags but

How to create a empty folder in google storage(bucket) using gsutil command?

How we can create the folder using gsutil command. I am using Bashoperator in airflow where I need to use the gsutil Bash command, Bucket is already created I w

ServiceNow integration with Airflow

Can we integrate ServiceNow with Airflow ? I mean if there is any DAG failure, can we rerun the failed DAG/tasks by submitting a ServiceNow request ? Also can w

How to import SlackWebHookOperator in Airflow?

I want to integrate Slack alert messages when a task fail in Airflow with SlackWebHookOperator. I have issue with the import of the operator. In this tutorial