Apache Airflow Provider for Apache TinkerPop

raw JSON →
1.1.3 verified Sat May 09 auth: no python

Apache Airflow provider to interact with Apache TinkerPop graph databases. Version 1.1.3 was released in 2025, with a monthly release cadence. Requires Python >=3.10.

pip install apache-airflow-providers-apache-tinkerpop

Common errors

error ModuleNotFoundError: No module named 'airflow.providers.apache.tinkerpop' ↓
cause Provider package not installed or Airflow environment not activated.
fix
Run 'pip install apache-airflow-providers-apache-tinkerpop' and ensure Airflow is installed.
error TypeError: __init__() got an unexpected keyword argument 'gremlin_query' ↓
cause Using an older version of the provider that expected a 'query' parameter.
fix
Upgrade to latest provider: 'pip install --upgrade apache-airflow-providers-apache-tinkerpop'

Warnings

gotcha TinkerpopOperator requires a gremlin_query parameter; if omitted, the operator fails at runtime. ↓
fix Always set the gremlin_query argument.
gotcha The hook uses TCP port 8182 by default, but many environments use different ports. Verify connectivity. ↓
fix Explicitly set 'port' in the hook or operator.
deprecated In older versions, the connection type was 'tinkerpop'; ensure you use the correct connection ID in Airflow. ↓
fix Update connection to use conn_type='tinkerpop'.

Imports

Quickstart

Basic DAG using TinkerpopOperator to run a Gremlin query.

from datetime import datetime
from airflow import DAG
from airflow.providers.apache.tinkerpop.operators.tinkerpop import TinkerpopOperator

dag = DAG('tinkerpop_example', start_date=datetime(2023,1,1), schedule=None)
task = TinkerpopOperator(
    task_id='query_graph',
    gremlin_query="g.V().limit(1)",
    host='localhost',
    port=8182,
    dag=dag
)
last verified Sat May 09
next check Fri Aug 07