andrei created AIRFLOW-1080:
-------------------------------
Summary: airflow_local_settings: no effect on task.template_fields
changes in policy function
Key: AIRFLOW-1080
URL: https://issues.apache.org/jira/browse/AIRFLOW-1080
Project: Apache Airflow
Issue Type: Bug
Components: configuration
Affects Versions: 1.9.0
Reporter: andrei
Priority: Minor
I am trying to add new template_fields to some operators. I have tried to do
that using policy() function, but not succeed.
Maybe it's wrong way to change existing operators?
{quote}
def policy(task):
if task.__class__.__name__ == 'FileToGoogleCloudStorageOperator':
print('I am working!')
task.template_fields = ('bucket', )
task.resolve_template_files()
task.render_templates()
{quote}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)