Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

Apache TinkerPop Operators

GremlinOperator

Executes Gremlin queries on a remote Gremlin Server.

For parameter definition take a look at GremlinOperator.

Using the operator

An example usage of the GremlinOperator to query from gremlin server is as follows:

tests/system/apache/tinkerpop/example_gremlin_dag.py[source]


gremlin_task = GremlinOperator(
    task_id="run_gremlin_query", gremlin_conn_id="gremlin_conn_id", query="g.V()"
)

Reference

For further information, look at: https://tinkerpop.apache.org/gremlin.html

Was this entry helpful?