You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "andrei (JIRA)" <ji...@apache.org> on 2017/04/06 07:53:41 UTC

[jira] [Created] (AIRFLOW-1080) airflow_local_settings: no effect on task.template_fields changes in policy function

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)