Workflow.query

Workflow.query(query_string) → Query

Execute a SQL query scoped to a workflow. Table names do not need to be fully qualified, since all tables are assumed to be within the workflow.

Parameters:

query_string : str The SQL query to execute. Must follow the Redivis SQL query syntax.

Returns:

Query

Examples

workflow = redivis.user("imathews").workflow("example_workflow_climate_analysis")

# The query can reference any table in the workflow
query = workflow.query("""
    SELECT
        id,
        EXTRACT(YEAR FROM date) AS year,
        SUM(value) AS annual_precip
    FROM daily_observations
    WHERE (element = 'PRCP')
    GROUP BY id, year
""")
query.to_pandas_dataframe()
# 	id	        year	    annual_precip
# 0	CA0023026HN	2003	    2925.0
# ...