From commits-return-76112-archive-asf-public=cust-asf.ponee.io@airflow.apache.org Mon Nov 18 21:59:31 2019 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id 1D648180657 for ; Mon, 18 Nov 2019 22:59:31 +0100 (CET) Received: (qmail 46770 invoked by uid 500); 18 Nov 2019 21:59:30 -0000 Mailing-List: contact commits-help@airflow.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airflow.apache.org Delivered-To: mailing list commits@airflow.apache.org Received: (qmail 46760 invoked by uid 99); 18 Nov 2019 21:59:30 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 18 Nov 2019 21:59:30 +0000 From: GitBox To: commits@airflow.apache.org Subject: [GitHub] [airflow] tfindlay-au opened a new pull request #6604: [AIRFLOW-5920] *DRAFT* Neo4j operator and hook Message-ID: <157411437031.10885.11541490342337644693.gitbox@gitbox.apache.org> Date: Mon, 18 Nov 2019 21:59:30 -0000 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit tfindlay-au opened a new pull request #6604: [AIRFLOW-5920] *DRAFT* Neo4j operator and hook URL: https://github.com/apache/airflow/pull/6604 Make sure you have checked _all_ steps below. ### Jira [AIRFLOW-5920] ### Description These changes add the ability for a pipeline to execute a cypher query as part of a DAG pipeline. The query is executed against an Airflow managed connection (host, port, username, password) using the Neo4j python library: https://neo4j.com/docs/api/python-driver/current/ ### Tests Unit tests will be submitted shortly. ### Commits ### Documentation Documentation will be comming shortly. Just waiting proof for a proof read. Usage will look like: ``` t4 = Neo4JOperator( task_id="RunQuery", n4j_conn_id="ExampleN4J", cypher_query="MATCH (n) RETURN id(n)", filename="myfile.csv", fail_on_no_results=True, dag=dag ) ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: users@infra.apache.org With regards, Apache Git Services