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

[jira] [Updated] (AIRFLOW-1141) Remove DAG.crawl_for_tasks method

     [ https://issues.apache.org/jira/browse/AIRFLOW-1141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jeeyoung Kim updated AIRFLOW-1141:
----------------------------------
    Description: 
Currently {{DAG}} class has the method:

{noformat}
    def crawl_for_tasks(objects):
        """
        Typically called at the end of a script by passing globals() as a
        parameter. This allows to not explicitly add every single task to the
        dag explicitly.
        """
        raise NotImplementedError("")
{noformat}

which is not called or tested from anywhere:
{noformat}
$ git grep crawl_for_tasks
airflow/models.py:    def crawl_for_tasks(objects):
{noformat}
 I suggest removing this method as it doesn't do anything and there's no documentation related to it. Moreover, if one creates a subclass of DAG, pylint returns the following warning: {{Method 'crawl_for_tasks' is abstract in class 'DAG' but is not overridden (abstract-method)}}

  was:
Currently {{DAG}} class has the method:

{noformat}
    def crawl_for_tasks(objects):
        """
        Typically called at the end of a script by passing globals() as a
        parameter. This allows to not explicitly add every single task to the
        dag explicitly.
        """
        raise NotImplementedError("")
{noformat}

which is not called or tested from anywhere. I suggest removing this method as it doesn't do anything and there's no documentation related to it. Moreover, if one creates a subclass of DAG, pylint returns the following warning: {{Method 'crawl_for_tasks' is abstract in class 'DAG' but is not overridden (abstract-method)}}


> Remove DAG.crawl_for_tasks method
> ---------------------------------
>
>                 Key: AIRFLOW-1141
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-1141
>             Project: Apache Airflow
>          Issue Type: Task
>            Reporter: Jeeyoung Kim
>            Priority: Trivial
>
> Currently {{DAG}} class has the method:
> {noformat}
>     def crawl_for_tasks(objects):
>         """
>         Typically called at the end of a script by passing globals() as a
>         parameter. This allows to not explicitly add every single task to the
>         dag explicitly.
>         """
>         raise NotImplementedError("")
> {noformat}
> which is not called or tested from anywhere:
> {noformat}
> $ git grep crawl_for_tasks
> airflow/models.py:    def crawl_for_tasks(objects):
> {noformat}
>  I suggest removing this method as it doesn't do anything and there's no documentation related to it. Moreover, if one creates a subclass of DAG, pylint returns the following warning: {{Method 'crawl_for_tasks' is abstract in class 'DAG' but is not overridden (abstract-method)}}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)