[ 
https://issues.apache.org/jira/browse/AIRFLOW-245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331683#comment-15331683
 ] 

Alexandr Nikitin commented on AIRFLOW-245:
------------------------------------------

A PR to address this: https://github.com/apache/incubator-airflow/pull/1596

> Access to task instance from custom Executor
> --------------------------------------------
>
>                 Key: AIRFLOW-245
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-245
>             Project: Apache Airflow
>          Issue Type: Improvement
>          Components: executor
>            Reporter: Alexandr Nikitin
>
> I'm writing a custom executor that executes tasks on mesos and I want to have 
> access to task instances from it. So that I can reuse all existing operators 
> e.g. DockerOperator and access its fields like image, command, volumes and 
> transform them to mesos.
> This can be done by changing `def execute_async(self, key, command, 
> queue=None):` in `BaseExecutor`.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to