Create Sync Dag

1 from airweave import AirweaveSDK, DagEdgeCreate, DagNodeCreate 2 3 client = AirweaveSDK( 4 api_key="YOUR_API_KEY", 5 ) 6 client.dag.create_sync_dag( 7 sync_id="sync_id", 8 name="name", 9 sync_dag_create_sync_id="sync_id", 10 nodes=[ 11 DagNodeCreate( 12 type="source", 13 name="name", 14 ) 15 ], 16 edges=[ 17 DagEdgeCreate( 18 from_node_id="from_node_id", 19 to_node_id="to_node_id", 20 ) 21 ], 22 )

1 { 2 "name": "name", 3 "sync_id": "sync_id", 4 "id": "id", 5 "organization_id": "organization_id", 6 "created_by_email": "created_by_email", 7 "modified_by_email": "modified_by_email", 8 "nodes": [ 9 { 10 "type": "source", 11 "name": "name", 12 "id": "id", 13 "dag_id": "dag_id", 14 "organization_id": "organization_id", 15 "created_by_email": "created_by_email", 16 "modified_by_email": "modified_by_email", 17 "config": { 18 "key": "value" 19 }, 20 "connection_id": "connection_id", 21 "entity_definition_id": "entity_definition_id", 22 "transformer_id": "transformer_id" 23 } 24 ], 25 "edges": [ 26 { 27 "from_node_id": "from_node_id", 28 "to_node_id": "to_node_id", 29 "id": "id", 30 "dag_id": "dag_id", 31 "organization_id": "organization_id", 32 "created_by_email": "created_by_email", 33 "modified_by_email": "modified_by_email" 34 } 35 ], 36 "description": "description" 37 }

Create a new DAG definition for a sync.

Path parameters

sync_idstringRequired

Request

This endpoint expects an object.

namestringRequired

sync_idstringRequired

nodeslist of objectsRequired

edgeslist of objectsRequired

descriptionstringOptional

Response

Successful Response

namestring

sync_idstringformat: "uuid"

idstringformat: "uuid"

organization_idstringformat: "uuid"

created_by_emailstring

modified_by_emailstring

nodeslist of objects

edgeslist of objects

descriptionstringOptional

Path parameters

Headers

Request

Response

Errors