auth = dmda.DomoTokenAuth(
domo_instance=os.environ['DOMO_DOJO_INSTANCE'],
domo_access_token=os.environ["DOMO_DOJO_ACCESS_TOKEN"],
)
dataflows = (await dataflow_routes.get_dataflows(auth = auth)).response
dataflow_id = dataflows[0]['id']
versions = (await dataflow_routes.get_dataflow_versions(auth =auth, dataflow_id = dataflow_id)).response
version_id = versions[0]['id']Dataflow
a class based approach to interacting with dataflows
DomoDataflow
DomoDataflow (id:str, name:str=None, auth:domolibrary.client.DomoAuth.DomoAuth=None, owner:str=None, description:str=None, tags:list[str]=None, actions:list[domolibrary.classes.DomoDataflow_Action.DomoDa taflow_Action]=None, version_id:int=None, version_number:int=None, versions:List[dict]=None, History: domolibrary.classes.DomoDataflow_History.DomoDataflow_Histo ry=None, Lineage:domolibrary.classes.DomoLineage.DomoLineage=None)
sample implementation of get_by_id
domo_dataflow = await DomoDataflow.get_by_id(dataflow_id=dataflow_id, auth=auth)
domo_dataflowDomoDataflow(id=127, name='@Zel ETL', owner=None, description=None, tags=None, actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)]), DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])]), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])]), DomoDataflow_Action(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name='Join Data', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018', '2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])])]), DomoDataflow_Action(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name='Add Formula', datasource_id=None, sql=None, depends_on=['e9e76a06-7a82-429a-bb3f-f1e912e1d6bc'], parent_actions=[DomoDataflow_Action(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name='Join Data', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018', '2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])])])]), DomoDataflow_Action(id='f32d6203-2ab9-42b0-b44b-f0ee823202f3', type='PublishToVault', name='@Zel output', datasource_id='81121c6d-61c8-4723-b558-a90d16c1e10a', sql=None, depends_on=['9a80fd0d-33fb-4085-a20a-3ab856f5a762'], parent_actions=[DomoDataflow_Action(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name='Add Formula', datasource_id=None, sql=None, depends_on=['e9e76a06-7a82-429a-bb3f-f1e912e1d6bc'], parent_actions=[DomoDataflow_Action(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name='Join Data', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018', '2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])])])])])], version_id=None, version_number=None, versions=None, History=DomoDataflow_History(execution_history=None), Lineage=DomoLineage(parent_type='DATAFLOW', parent_id=127))lineage = await domo_dataflow.Lineage.get(
return_raw=True,
debug_api = False
)await lineage[0].Lineage.get()[127]--------------------------------------------------------------------------- RecursionError Traceback (most recent call last) Cell In[10], line 1 ----> 1 await lineage[0].Lineage.get() File /workspaces/domolibrary/domolibrary/classes/DomoLineage.py:172, in get(self, total_list, debug_api, session, return_raw, tested_ids) 167 await entity.Lineage.get( 168 total_list=total_list, debug_api=debug_api, session=session, tested_ids=tested_ids 169 ) 171 for child in entity.Lineage.upstream_lineage_ls: --> 172 if child not in total_list: 173 total_list.append(child) 175 return total_list File <string>:4, in __eq__(self, other) File <string>:4, in __eq__(self, other) File <string>:4, in __eq__(self, other) File <string>:4, in __eq__(self, other) [... skipping similar frames: __eq__ at line 4 (184 times), __eq__ at line 4 (183 times)] File <string>:4, in __eq__(self, other) File <string>:4, in __eq__(self, other) RecursionError: maximum recursion depth exceeded in comparison
sample retrieval that also interacts with dataflow history from DomoDataflow_History
note will return actions history
await domo_dataflow.History.get_execution_history(maximum=5)[DomoDataflow_History_Execution(id=653071, dataflow_id=127, dataflow_execution_id='c869a2f0-64cd-4037-8579-32720c4f2321', dataflow_version=509, begin_time=datetime.datetime(2025, 1, 30, 21, 48, 10), end_time=datetime.datetime(2025, 1, 30, 21, 48, 20), last_updated=datetime.datetime(2025, 1, 30, 21, 48, 20), is_failed=False, state='SUCCESS', activation_type='MANUAL', data_processor='MAGIC', telemetry=[{'name': 'activeOptimizations', 'value': 'd'}], execution_stats={'total_bytes_written': 0, 'total_rows_read': 0, 'total_bytes_read': 0, 'mean_download_rate_kbps': 0.0, 'total_rows_written': 0}, action_results=[DomoDataflow_ActionResult(id='6d9d3106-a084-481d-a69d-74840f17d018', type='DataHubManifestLoaderAction', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 215000), end_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 215000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 215000), end_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 215000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 317000), end_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 317000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 317000), end_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 317000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 218000), end_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 422000), duration_in_sec=0.204), DomoDataflow_ActionResult(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 422000), end_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 422000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='f32d6203-2ab9-42b0-b44b-f0ee823202f3', type='PublishToVault', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 540000), end_time=datetime.datetime(2025, 1, 30, 21, 48, 17, 540000), duration_in_sec=0.0)]),
DomoDataflow_History_Execution(id=653067, dataflow_id=127, dataflow_execution_id='02e5d816-82f0-47c0-ab92-2d22a58cae47', dataflow_version=509, begin_time=datetime.datetime(2025, 1, 30, 21, 43, 16), end_time=datetime.datetime(2025, 1, 30, 21, 43, 26), last_updated=datetime.datetime(2025, 1, 30, 21, 43, 26), is_failed=False, state='SUCCESS', activation_type='MANUAL', data_processor='MAGIC', telemetry=[{'name': 'activeOptimizations', 'value': 'd'}], execution_stats={'total_bytes_written': 0, 'total_rows_read': 0, 'total_bytes_read': 0, 'mean_download_rate_kbps': 0.0, 'total_rows_written': 0}, action_results=[DomoDataflow_ActionResult(id='6d9d3106-a084-481d-a69d-74840f17d018', type='DataHubManifestLoaderAction', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 719000), end_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 719000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 719000), end_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 719000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 832000), end_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 832000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 832000), end_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 832000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 741000), end_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 916000), duration_in_sec=0.175), DomoDataflow_ActionResult(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 916000), end_time=datetime.datetime(2025, 1, 30, 21, 43, 23, 916000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='f32d6203-2ab9-42b0-b44b-f0ee823202f3', type='PublishToVault', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 21, 43, 24, 33000), end_time=datetime.datetime(2025, 1, 30, 21, 43, 24, 42000), duration_in_sec=0.009)]),
DomoDataflow_History_Execution(id=653035, dataflow_id=127, dataflow_execution_id='6c05dbb2-53f1-48fb-84f5-18e3b7c76597', dataflow_version=509, begin_time=datetime.datetime(2025, 1, 30, 20, 2, 37), end_time=datetime.datetime(2025, 1, 30, 20, 2, 47), last_updated=datetime.datetime(2025, 1, 30, 20, 2, 47), is_failed=False, state='SUCCESS', activation_type='MANUAL', data_processor='MAGIC', telemetry=[{'name': 'activeOptimizations', 'value': 'd'}], execution_stats={'total_bytes_written': 0, 'total_rows_read': 0, 'total_bytes_read': 0, 'mean_download_rate_kbps': 0.0, 'total_rows_written': 0}, action_results=[DomoDataflow_ActionResult(id='6d9d3106-a084-481d-a69d-74840f17d018', type='DataHubManifestLoaderAction', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 20, 2, 44, 953000), end_time=datetime.datetime(2025, 1, 30, 20, 2, 44, 953000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 20, 2, 44, 953000), end_time=datetime.datetime(2025, 1, 30, 20, 2, 44, 953000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 20, 2, 44, 975000), end_time=datetime.datetime(2025, 1, 30, 20, 2, 44, 975000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 20, 2, 44, 975000), end_time=datetime.datetime(2025, 1, 30, 20, 2, 44, 975000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 20, 2, 44, 964000), end_time=datetime.datetime(2025, 1, 30, 20, 2, 45, 51000), duration_in_sec=0.087), DomoDataflow_ActionResult(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 20, 2, 45, 51000), end_time=datetime.datetime(2025, 1, 30, 20, 2, 45, 51000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='f32d6203-2ab9-42b0-b44b-f0ee823202f3', type='PublishToVault', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 20, 2, 45, 266000), end_time=datetime.datetime(2025, 1, 30, 20, 2, 45, 266000), duration_in_sec=0.0)]),
DomoDataflow_History_Execution(id=652956, dataflow_id=127, dataflow_execution_id='9d529631-38a7-4816-bae5-53d1ae03a202', dataflow_version=509, begin_time=datetime.datetime(2025, 1, 30, 16, 32, 24), end_time=datetime.datetime(2025, 1, 30, 16, 32, 34), last_updated=datetime.datetime(2025, 1, 30, 16, 32, 34), is_failed=False, state='SUCCESS', activation_type='MANUAL', data_processor='MAGIC', telemetry=[{'name': 'activeOptimizations', 'value': 'd'}], execution_stats={'total_bytes_written': 0, 'total_rows_read': 0, 'total_bytes_read': 0, 'mean_download_rate_kbps': 0.0, 'total_rows_written': 0}, action_results=[DomoDataflow_ActionResult(id='6d9d3106-a084-481d-a69d-74840f17d018', type='DataHubManifestLoaderAction', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 21000), end_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 21000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 21000), end_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 21000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 134000), end_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 135000), duration_in_sec=0.001), DomoDataflow_ActionResult(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 134000), end_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 134000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 122000), end_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 236000), duration_in_sec=0.114), DomoDataflow_ActionResult(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 236000), end_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 236000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='f32d6203-2ab9-42b0-b44b-f0ee823202f3', type='PublishToVault', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 390000), end_time=datetime.datetime(2025, 1, 30, 16, 32, 32, 390000), duration_in_sec=0.0)]),
DomoDataflow_History_Execution(id=652940, dataflow_id=127, dataflow_execution_id='607b68f2-0dcd-40ad-9f59-caffc73470ab', dataflow_version=509, begin_time=datetime.datetime(2025, 1, 30, 15, 59, 32), end_time=datetime.datetime(2025, 1, 30, 15, 59, 41), last_updated=datetime.datetime(2025, 1, 30, 15, 59, 41), is_failed=False, state='SUCCESS', activation_type='MANUAL', data_processor='MAGIC', telemetry=[{'name': 'activeOptimizations', 'value': 'd'}], execution_stats={'total_bytes_written': 0, 'total_rows_read': 0, 'total_bytes_read': 0, 'mean_download_rate_kbps': 0.0, 'total_rows_written': 0}, action_results=[DomoDataflow_ActionResult(id='6d9d3106-a084-481d-a69d-74840f17d018', type='DataHubManifestLoaderAction', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 600000), end_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 600000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 600000), end_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 600000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 702000), end_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 703000), duration_in_sec=0.001), DomoDataflow_ActionResult(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 702000), end_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 702000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 683000), end_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 784000), duration_in_sec=0.101), DomoDataflow_ActionResult(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 784000), end_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 784000), duration_in_sec=0.0), DomoDataflow_ActionResult(id='f32d6203-2ab9-42b0-b44b-f0ee823202f3', type='PublishToVault', name=None, is_success=True, rows_processed=0, begin_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 939000), end_time=datetime.datetime(2025, 1, 30, 15, 59, 39, 940000), duration_in_sec=0.001)])]sample execute_dataflow
try:
domo_dataflow = DomoDataflow(id=dataflow_id, auth=auth)
print(await domo_dataflow.execute())
except dmde.DomoError as e:
print(e)ResponseGetData(status=200, response={'id': 653078, 'onboardFlowId': 127, 'previewRows': 0, 'dapDataFlowExecutionId': 'bede7b98-c2d0-474a-92f6-1778a4dabe28', 'beginTime': 1738274644141, 'lastUpdated': 1738274645102, 'state': 'CREATED', 'activationType': 'MANUAL', 'executionEngine': {'platform': 'K8S', 'engine': 'MAGIC'}, 'dataProcessor': 'MAGIC', 'dataFlowVersion': 509}, is_success=True, parent_class=None)Dataflow Versions
await DomoDataflow.get_by_version_id(
dataflow_id=dataflow_id, version_id=version_id, auth=auth, return_raw=False
)DomoDataflow(id=127, name='@Zel ETL', owner=None, description=None, tags=None, actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)]), DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])]), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])]), DomoDataflow_Action(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name='Join Data', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018', '2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])])]), DomoDataflow_Action(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name='Add Formula', datasource_id=None, sql=None, depends_on=['e9e76a06-7a82-429a-bb3f-f1e912e1d6bc'], parent_actions=[DomoDataflow_Action(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name='Join Data', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018', '2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])])])]), DomoDataflow_Action(id='f32d6203-2ab9-42b0-b44b-f0ee823202f3', type='PublishToVault', name='@Zel output', datasource_id='81121c6d-61c8-4723-b558-a90d16c1e10a', sql=None, depends_on=['9a80fd0d-33fb-4085-a20a-3ab856f5a762'], parent_actions=[DomoDataflow_Action(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name='Add Formula', datasource_id=None, sql=None, depends_on=['e9e76a06-7a82-429a-bb3f-f1e912e1d6bc'], parent_actions=[DomoDataflow_Action(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name='Join Data', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018', '2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])])])])])], version_id=509, version_number=1, versions=None, History=DomoDataflow_History(execution_history=None), Lineage=DomoLineage(parent_type='DATAFLOW', parent_id=127))domo_dataflow = DomoDataflow(id=dataflow_id, auth=auth)
await domo_dataflow.get_versions(return_raw=False)[DomoDataflow(id=127, name='@Zel ETL', owner=None, description=None, tags=None, actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)]), DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])]), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])]), DomoDataflow_Action(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name='Join Data', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018', '2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])])]), DomoDataflow_Action(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name='Add Formula', datasource_id=None, sql=None, depends_on=['e9e76a06-7a82-429a-bb3f-f1e912e1d6bc'], parent_actions=[DomoDataflow_Action(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name='Join Data', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018', '2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])])])]), DomoDataflow_Action(id='f32d6203-2ab9-42b0-b44b-f0ee823202f3', type='PublishToVault', name='@Zel output', datasource_id='81121c6d-61c8-4723-b558-a90d16c1e10a', sql=None, depends_on=['9a80fd0d-33fb-4085-a20a-3ab856f5a762'], parent_actions=[DomoDataflow_Action(id='9a80fd0d-33fb-4085-a20a-3ab856f5a762', type='ExpressionEvaluator', name='Add Formula', datasource_id=None, sql=None, depends_on=['e9e76a06-7a82-429a-bb3f-f1e912e1d6bc'], parent_actions=[DomoDataflow_Action(id='e9e76a06-7a82-429a-bb3f-f1e912e1d6bc', type='MergeJoin', name='Join Data', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018', '2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None), DomoDataflow_Action(id='2c3aa4bb-07f5-45f4-abfa-26e9747f1fa5', type='Constant', name='Add Constants', datasource_id=None, sql=None, depends_on=['b8d8da16-2db0-4d88-9287-b349901d7d54'], parent_actions=[DomoDataflow_Action(id='b8d8da16-2db0-4d88-9287-b349901d7d54', type='GroupBy', name='Group By', datasource_id=None, sql=None, depends_on=['49f0cb44-56bb-4e19-ae8b-b83be193e3c6'], parent_actions=[DomoDataflow_Action(id='49f0cb44-56bb-4e19-ae8b-b83be193e3c6', type='Filter', name='LostConnectivity and Disregard', datasource_id=None, sql=None, depends_on=['6d9d3106-a084-481d-a69d-74840f17d018'], parent_actions=[DomoDataflow_Action(id='6d9d3106-a084-481d-a69d-74840f17d018', type='LoadFromVault', name='@Zel Dojo', datasource_id='864c1409-461e-46fc-b4b3-0ed644903782', sql=None, depends_on=None, parent_actions=None)])])])])])])], version_id=509, version_number=1, versions=None, History=DomoDataflow_History(execution_history=None), Lineage=DomoLineage(parent_type='DATAFLOW', parent_id=127))]