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 ABE59200C6C for ; Fri, 5 May 2017 18:41:51 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id AA8BB160BAF; Fri, 5 May 2017 16:41:51 +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 EFB2F160BAA for ; Fri, 5 May 2017 18:41:50 +0200 (CEST) Received: (qmail 11647 invoked by uid 500); 5 May 2017 16:41:50 -0000 Mailing-List: contact dev-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 dev@airflow.incubator.apache.org Received: (qmail 11635 invoked by uid 99); 5 May 2017 16:41:49 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 05 May 2017 16:41:49 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 68BD4C137A for ; Fri, 5 May 2017 16:41:49 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.479 X-Spam-Level: ** X-Spam-Status: No, score=2.479 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=industrydive-com.20150623.gappssmtp.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id ZxefcDAALbM2 for ; Fri, 5 May 2017 16:41:47 +0000 (UTC) Received: from mail-lf0-f53.google.com (mail-lf0-f53.google.com [209.85.215.53]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 22ADD5F520 for ; Fri, 5 May 2017 16:41:47 +0000 (UTC) Received: by mail-lf0-f53.google.com with SMTP id j1so6506267lfh.2 for ; Fri, 05 May 2017 09:41:47 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=industrydive-com.20150623.gappssmtp.com; s=20150623; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=HnPrLDYjTafMwHNP8TkaOlXBSLx9v39+QSnhSiKS76M=; b=EzwHbtXDmeS2l8L4MSaxIYaLG05wK1/ofBfVOEZ1/hfoQHY+scFF5n9U2x2kPraIMl yoQ3queKfcS1ynIRQVeb9bEmpNGOEd39fDpvMdLnJnpC+nyEzcdHDIymFqdRHB4E49T9 lzORe0h3y73FmhhNZDirW/151C7m/1vSC+cw/lsV0YwSxR5nkQs4FGX86WWRzvoYpx1h sOkUAktvvt6J2oP13Uncuv7/Do3uaMuF/4XzatUQTk8w2h7j0JXw+xQyz8ndleagB6/r G/3+5x1r7vPL/CFUeCNa+9MZMtq8mHXODD4frAS3ZhA0U4lisPVMN8eBFsnBoyL/iJwW QaTA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=HnPrLDYjTafMwHNP8TkaOlXBSLx9v39+QSnhSiKS76M=; b=e4MEwvzA3Kd6H10wF024V9oVRL38PPECbeTX8q99MYnaXf6tN6RniZe1vO+W9GzLn5 Hsx0PcQYp3thDOXKCkSuK028I2jYtJLWP05pJmLF6/lfVRQnyfkcXWpAM4JYaA/RkYJI XJ1j88zchxjmolwCjWDtJKqwSRFb8hp5gKvKPWuur+fJTEGupeCYyV4HF3aRVd6gQT75 gmOvG8K+Rz6dEyZ0zO38wYiM3rNyCsVx45QJPHrlVpZxgJ27lqx/rQKSLihmJ1OmHL+c UeRKyo5btG6+NhVx2oNiQkDBe2F+hS2hVeHydZrYSJsj2FhmTPE01+ZDtFYqm5Ai9KTl Nfhw== X-Gm-Message-State: AN3rC/7N/Mcoln7zF1dGQQNLpoB9S4z2LpHMjMcjt9abeCGVckcOgjpK jSOhPbxQIrT2L+KAy2jJKRmgmwXeSc3G X-Received: by 10.46.32.35 with SMTP id g35mr19349215ljg.126.1494002500046; Fri, 05 May 2017 09:41:40 -0700 (PDT) MIME-Version: 1.0 Received: by 10.25.209.82 with HTTP; Fri, 5 May 2017 09:40:59 -0700 (PDT) In-Reply-To: References: From: Laura Lorenz Date: Fri, 5 May 2017 12:40:59 -0400 Message-ID: Subject: Re: Airflow Testing Library To: dev@airflow.incubator.apache.org Content-Type: multipart/alternative; boundary=001a1142c9804f2a0d054ec99080 archived-at: Fri, 05 May 2017 16:41:51 -0000 --001a1142c9804f2a0d054ec99080 Content-Type: text/plain; charset=UTF-8 We do! We developed our own little in-house DAG test framework which we could share insights on/would love to hear what other folks are up to. Basically we use mock a DAG's input data, use the BackfillJob API directly to call a DAG in a test, and compare its outputs to the intended result given the inputs. We use docker/docker-compose to manage services, and split our dev and test stack locally so that the tests have their own scheduler and metadata database and so that our CI tool knows how to construct the test stack as well. We co-opted the BackfillJob API for our own purposes here, but it seemed overly complicated and fragile to start and interact with our own in-test-process executor like we saw in a few of the tests in the Airflow test suite. So I'd be really interested on finding a way to streamline how to describe a test executor for both the Airflow test suite and people's own DAG testing and make that a first class type of API. Laura On Fri, May 5, 2017 at 11:46 AM, Sam Elamin wrote: > Hi All > > A few people in the Spark community are interested in writing a testing > library for Airflow. We would love anyone who uses Airflow heavily in > production to be involved > > At the moment (AFAIK) testing your DAGs is a bit of a pain, especially if > you want to run them in a CI server > > Is anyone interested in being involved in the discussion? > > Kind Regards > Sam > --001a1142c9804f2a0d054ec99080--