Uploaded image for project: 'Apache Airflow'
  1. Apache Airflow
  2. AIRFLOW-6598

DAG task queries a neo4j compatiable graph database

    XMLWordPrintableJSON

    Details

    • Type: New Feature
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.10.10
    • Fix Version/s: None
    • Component/s: hooks, operators
    • Labels:
      None

      Description

      Story

      As a developer
      When I create a DAG task
      I want to query a neo4j compatiable graph database
      So that I can use the results

      Assumptions

      • DAG Task can specify output type
      • Processing the results of the query is up to the developer

      In Scope

      • Ability to export results to CSV
      • Support for DML queries.
      • Resulting row count validation
      • Target space validation
      • Support for handling empty query responses
      • Bolt and Bolt+routing protocol
      • Correct failure handling (Connection, Query failure)

      Out of Scope

      • No other output format (other than CSV) supported. eg. Parquet, Avro, JSON
      • Ability to use the bulk export API
      • Ability to use the bulk import API

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                tfindlay Timothy Findlay
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated: