grai_source_dbt_cloud
loader

Event Objects

class Event()

DbtCloudConnector Objects

class DbtCloudConnector()

default_account

@cached_property
def default_account() -> dict

get_nodes_and_edges

def get_nodes_and_edges()

get_events

def get_events(last_event_date) -> List[Event]

Arguments:

last_event_date:

Returns:

get_run_nodes

def get_run_nodes(account_id: str, run_id: str) -> List[str]

Arguments:

account_id (str): run_id (str):

Returns:

get_runs

def get_runs(account_id: str, last_event_date)

Arguments:

account_id (str): last_event_date:

Returns: