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:

   :param retry_delay: delay between retries
   :type retry_delay: timedelta

Post a Comment for "Airflow 1.9.0 ExternalTaskSensor Retry_delay=30 Yields TypeError: Can't Pickle _thread.RLock Objects"