Prefect Collection for interacting with CubeJS in your flows: prefect-cubejs

Docs

https://alessandrolollo.github.io/prefect-cubejs/

Code

Examples

from prefect import flow
from prefect_cubejs.tasks import (
    run_query
)


@flow
def example_flow():
    run_query(
        subdomain="<your Cube Cloud subdomain>",
        api_secret="<your Cube.js API secret>",
        query="<a Cube.js JSON formatted query>"
    )

example_flow()