Skip to content Skip to sidebar Skip to footer

Airflow 1.9.0 Externaltasksensor Retry_delay=30 Yields Typeerror: Can't Pickle _thread.rlock Objects

As the titles says; in Airflow 1.9.0 if you use the retry_delay=30 (or any other number) parameter with the ExternalTaskSensor, the DAG will run just fine, until you want to clear

Solution 1:

After looking at this problem again, the documentation clearly states that retry_delay should be a timedelta. So its just lucky that the DAG works if you enter an integer instead of a timedelta for retry_delay.

In models.py, BaseOperator:

:paramretry_delay: delay between retries
   :typeretry_delay: timedelta

Post a Comment for "Airflow 1.9.0 Externaltasksensor Retry_delay=30 Yields Typeerror: Can't Pickle _thread.rlock Objects"