|
|
|
|
|
|
|
|
datasource_nodes = workflow.graph_dict.get("nodes", []) |
|
|
datasource_nodes = workflow.graph_dict.get("nodes", []) |
|
|
datasource_plugins = [] |
|
|
datasource_plugins = [] |
|
|
for datasource_node in datasource_nodes: |
|
|
for datasource_node in datasource_nodes: |
|
|
if datasource_node.get("type") == "datasource": |
|
|
|
|
|
datasource_node_data = datasource_node.get("data", {}) |
|
|
|
|
|
|
|
|
if datasource_node.get("data", {}).get("type") == "datasource": |
|
|
|
|
|
datasource_node_data = datasource_node["data"] |
|
|
if not datasource_node_data: |
|
|
if not datasource_node_data: |
|
|
continue |
|
|
continue |
|
|
|
|
|
|