My attempts include: [ here i have python 3.9 so my constraints is 3.9] I created a virtual environment and attempted to install Apache-Airflow by using pip install ‘apache-airflow==2.5.1’ / —constraint "https://raw.githubusercontent.com/apache/airflow/constraints-2.5.1/constraints-3.9.txt," but I received an error that I couldn’t understand, so I looked on the stack community for advice and learned that I needed… Read More I am not able to install Apache Airflow in Windows

I have a simple DAG with 2 PythonOperator and schedule interval for 2 minutes: with DAG(dag_id=’example_cron’, schedule_interval=’*/2 * * * *’, start_date=days_ago(2)) as dag: def task1_func(ti): print("start task 1") time.sleep(random.randint(0, 70)) print("end task 1") def task2_func(ti): print("start task 2") time.sleep(random.randint(0, 70)) print("end task 2") task1 = PythonOperator(task_id=’task1′, python_callable=task1_func, provide_context=True) task2 = PythonOperator(task_id=’task2′, python_callable=task2_func, provide_context=True) task1… Read More How to schedule the airflow DAG to run just after the end of the previous running DAG?

We are doing a migration between new and old Airflow and we were trying to implement a trigger from Airflow1 to Airflow2(and vice-versa), is it possible? >Solution : Since running Airflow 1 code in an Airflow 2 instance will likely result in errors, I assume you intend to have two Airflow instances? One running Airflow… Read More Is it possible to trigger an Airflow 2 dag from an Airflow 1 dag, and viceversa?