Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id DD9F2200C76 for ; Sat, 13 May 2017 12:58:09 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id DC7C1160BC6; Sat, 13 May 2017 10:58:09 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 38829160BB7 for ; Sat, 13 May 2017 12:58:09 +0200 (CEST) Received: (qmail 53333 invoked by uid 500); 13 May 2017 10:58:08 -0000 Mailing-List: contact commits-help@airflow.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airflow.incubator.apache.org Delivered-To: mailing list commits@airflow.incubator.apache.org Received: (qmail 53315 invoked by uid 99); 13 May 2017 10:58:08 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 13 May 2017 10:58:08 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id D4B051890F8 for ; Sat, 13 May 2017 10:58:07 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -100.002 X-Spam-Level: X-Spam-Status: No, score=-100.002 tagged_above=-999 required=6.31 tests=[RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id gCYFFMKPCt7r for ; Sat, 13 May 2017 10:58:07 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 6034B5FD6D for ; Sat, 13 May 2017 10:58:06 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 6513DE0D50 for ; Sat, 13 May 2017 10:58:05 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 561692431D for ; Sat, 13 May 2017 10:58:04 +0000 (UTC) Date: Sat, 13 May 2017 10:58:04 +0000 (UTC) From: "ASF subversion and git services (JIRA)" To: commits@airflow.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (AIRFLOW-935) Impossible to use plugin executors MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Sat, 13 May 2017 10:58:10 -0000 [ https://issues.apache.org/jira/browse/AIRFLOW-935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009265#comment-16009265 ] ASF subversion and git services commented on AIRFLOW-935: --------------------------------------------------------- Commit 08a784ede6ffe1a2389255e1c6d597e9b2131080 in incubator-airflow's branch refs/heads/master from [~stverhae] [ https://git-wip-us.apache.org/repos/asf?p=incubator-airflow.git;h=08a784e ] [AIRFLOW-860][AIRFLOW-935] Fix plugin executor import cycle and executor selection When a plugin is made with a custom Operator and executor, an import cycle occurs when the executor is chosen in airflow.cfg because the executors/__init__.py starts loading plugins too early. changed DEFAULT_EXECUTOR use to a function call which returns the default executor. This lazy approach fixes the import cycle. revision eb5982d (included in 1.8) breaks plugin executors altogether. It makes a new module for every plugin, so import statements need to be adapted, but the executor selection is left unchanged, so it ends up assigning the plugin module as an executor. fixed executor selection to work with the new plugin modules system introduced in 1.8. in Airflow.cfg a executor can now be specified as {plugin_name}.{executor_name} Fixes: - https://issues.apache.org/jira/browse/AIRFLOW-860 - https://issues.apache.org/jira/browse/AIRFLOW-935 Closes #2120 from stverhae/master > Impossible to use plugin executors > ---------------------------------- > > Key: AIRFLOW-935 > URL: https://issues.apache.org/jira/browse/AIRFLOW-935 > Project: Apache Airflow > Issue Type: Bug > Components: executor, plugins > Affects Versions: Airflow 1.8, 1.9.0 > Reporter: Stijn Verhaegen > > revision eb5982d (included in 1.8) breaks plugin executors altogether. It makes a new module for every plugin, so import statements need to be adapted, but the executor selection is left unchanged, so it ends up assigning the plugin module as an executor. > To reproduce: take any plugin which defines a custom executor and try to get it loaded by setting `executor` in the airflow.cfg -- This message was sent by Atlassian JIRA (v6.3.15#6346)