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

airflow.providers.apache.tinkerpop.operators.gremlin¶

Classes¶

GremlinOperator

Execute a Gremlin query.

Module Contents¶

class airflow.providers.apache.tinkerpop.operators.gremlin.GremlinOperator(query, gremlin_conn_id='gremlin_default', **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Execute a Gremlin query.

Parameters:

query (str) – The Gremlin query to execute.
gremlin_conn_id (str) – The connection ID to use when connecting to Gremlin. Defaults to “gremlin_default”.

template_fields = ('query',)[source]¶

query[source]¶

gremlin_conn_id = 'gremlin_default'[source]¶

execute(context)[source]¶

Derive when creating an operator.

Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

Was this entry helpful?