Hi Everyone
does anyone have any problems creating a
GoogleCloudStorageObjectUpdatedSensor
<https://github.com/apache/incubator-airflow/blob/master/airflow/contrib/sensors/gcs_sensor.py>
?
im on airflow 1.8 and i am getting an error of
*File
"/usr/local/lib/python2.7/dist-packages/airflow/contrib/sensors/gcs_sensor.py",
line 73, in ts_function*
*[2017-10-30 15:27:10,609] {base_task_runner.py:95} INFO - Subtask: return
context['execution_date'] + context['dag'].schedule_interval*
*[2017-10-30 15:27:10,609] {base_task_runner.py:95} INFO - Subtask:
TypeError: unsupported operand type(s) for +: 'datetime.datetime' and 'str'*
*[2017-10-30 15:27:15,906] {jobs.py:2097} INFO - Task exited with return
code 1*
i am not overwriting the ts_function so it seems the default ts_function
isn't working
When I try to overwrite the dag with
ts_fun = '{{ ds }}' or ts_func = '{{ execution_date}}'
I get
*''str' object is not callable'*
Which I assume is because its reading the date as a string instead of a
datetime object
Any help would be greatly apprecated?
Regards
Sam
