Skip to content

Last updated: July 22, 2025

DQOps REST API data_lineage operations

Operations related to managing and inspecting table and column lineage.

create_table_source_table

Creates a new source table of the table's data lineage.

Follow the link to see the source code on GitHub.

POST 

http://localhost:8888/api/connections/{connectionName}/schemas/{schemaName}/tables/{tableName}/lineage/sources/{sourceConnection}/schemas/{sourceSchema}/tables/{sourceTable}

Parameters of this method are described below

 Property name   Description                       Data type   Required 
connection_name Connection name string
schema_name Schema name string
table_name Table name string
source_connection Source connection name string
source_schema Source schema name string
source_table Source table name string

Request body

 Description                       Data type   Required 
Table lineage source list model TableLineageSourceSpec

Usage examples

Execution

curl -X POST http://localhost:8888/api/connections/sample_connection/schemas/sample_schema/tables/sample_table/lineage/sources/sample_connection/schemas/sample_schema/tables/sample_table^
    -H "Accept: application/json"^
    -H "Content-Type: application/json"^
    -d^
    "{\"source_connection\":\"\",\"source_schema\":\"\",\"source_table\":\"\"}"

Execution

from dqops import client
from dqops.client.api.data_lineage import create_table_source_table
from dqops.client.models import ColumnLineageSourceSpecMap, \
                                TableLineageSourceSpec

dqops_client = client.Client(
    'http://localhost:8888/'
)

request_body = TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

call_result = create_table_source_table.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client,
    json_body=request_body
)

Execution

from dqops import client
from dqops.client.api.data_lineage import create_table_source_table
from dqops.client.models import ColumnLineageSourceSpecMap, \
                                TableLineageSourceSpec

dqops_client = client.Client(
    'http://localhost:8888/'
)

request_body = TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

call_result = await create_table_source_table.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client,
    json_body=request_body
)

Execution

from dqops import client
from dqops.client.api.data_lineage import create_table_source_table
from dqops.client.models import ColumnLineageSourceSpecMap, \
                                TableLineageSourceSpec

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token
)

request_body = TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

call_result = create_table_source_table.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client,
    json_body=request_body
)

Execution

from dqops import client
from dqops.client.api.data_lineage import create_table_source_table
from dqops.client.models import ColumnLineageSourceSpecMap, \
                                TableLineageSourceSpec

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token
)

request_body = TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

call_result = await create_table_source_table.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client,
    json_body=request_body
)

delete_table_source_table

Deletes a specific data lineage source table of the given table.

Follow the link to see the source code on GitHub.

DELETE 

http://localhost:8888/api/connections/{connectionName}/schemas/{schemaName}/tables/{tableName}/lineage/sources/{sourceConnection}/schemas/{sourceSchema}/tables/{sourceTable}

Parameters of this method are described below

 Property name   Description                       Data type   Required 
connection_name Connection name string
schema_name Schema name string
table_name Table name string
source_connection Source connection name string
source_schema Source schema name string
source_table Source table name string

Usage examples

Execution

curl -X DELETE http://localhost:8888/api/connections/sample_connection/schemas/sample_schema/tables/sample_table/lineage/sources/sample_connection/schemas/sample_schema/tables/sample_table^
    -H "Accept: application/json"

Execution

from dqops import client
from dqops.client.api.data_lineage import delete_table_source_table

dqops_client = client.Client(
    'http://localhost:8888/'
)

call_result = delete_table_source_table.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)

Execution

from dqops import client
from dqops.client.api.data_lineage import delete_table_source_table

dqops_client = client.Client(
    'http://localhost:8888/'
)

call_result = await delete_table_source_table.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)

Execution

from dqops import client
from dqops.client.api.data_lineage import delete_table_source_table

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token
)

call_result = delete_table_source_table.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)

Execution

from dqops import client
from dqops.client.api.data_lineage import delete_table_source_table

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token
)

call_result = await delete_table_source_table.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)

get_table_data_lineage_graph

Returns a data lineage graph around the given table.

Follow the link to see the source code on GitHub.

GET 

http://localhost:8888/api/connections/{connectionName}/schemas/{schemaName}/tables/{tableName}/lineage/tree

Return value

 Property name   Description                       Data type 
table_lineage_model TableLineageModel

Parameters of this method are described below

 Property name   Description                       Data type   Required 
connection_name Connection name string
schema_name Schema name string
table_name Table name string
upstream Optional parameter to request upstream tables. By default, upstream tables are collected unless it is disabled by passing 'false'. boolean
downstream Optional parameter to request downstream tables. By default, downstream tables are collected unless it is disabled by passing 'false'. boolean

Usage examples

Execution

curl http://localhost:8888/api/connections/sample_connection/schemas/sample_schema/tables/sample_table/lineage/tree^
    -H "Accept: application/json"
Expand to see the returned result 
{
  "flows" : [ ],
  "data_lineage_fully_loaded" : true
}

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_data_lineage_graph

dqops_client = client.Client(
    'http://localhost:8888/',
    raise_on_unexpected_status=True
)

call_result = get_table_data_lineage_graph.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
TableLineageModel(
    flows=[

    ],
    data_lineage_fully_loaded=True
)

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_data_lineage_graph

dqops_client = client.Client(
    'http://localhost:8888/',
    raise_on_unexpected_status=True
)

call_result = await get_table_data_lineage_graph.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
TableLineageModel(
    flows=[

    ],
    data_lineage_fully_loaded=True
)

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_data_lineage_graph

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token,
    raise_on_unexpected_status=True
)

call_result = get_table_data_lineage_graph.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
TableLineageModel(
    flows=[

    ],
    data_lineage_fully_loaded=True
)

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_data_lineage_graph

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token,
    raise_on_unexpected_status=True
)

call_result = await get_table_data_lineage_graph.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
TableLineageModel(
    flows=[

    ],
    data_lineage_fully_loaded=True
)

get_table_source_table

Reads a specific data lineage source table defined on a target tale.

Follow the link to see the source code on GitHub.

GET 

http://localhost:8888/api/connections/{connectionName}/schemas/{schemaName}/tables/{tableName}/lineage/sources/{sourceConnection}/schemas/{sourceSchema}/tables/{sourceTable}

Return value

 Property name   Description                       Data type 
table_lineage_source_spec TableLineageSourceSpec

Parameters of this method are described below

 Property name   Description                       Data type   Required 
connection_name Connection name string
schema_name Schema name string
table_name Table name string
source_connection Source connection name string
source_schema Source schema name string
source_table Source table name string

Usage examples

Execution

curl http://localhost:8888/api/connections/sample_connection/schemas/sample_schema/tables/sample_table/lineage/sources/sample_connection/schemas/sample_schema/tables/sample_table^
    -H "Accept: application/json"
Expand to see the returned result 
{
  "source_connection" : "",
  "source_schema" : "",
  "source_table" : ""
}

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_source_table

dqops_client = client.Client(
    'http://localhost:8888/',
    raise_on_unexpected_status=True
)

call_result = get_table_source_table.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_source_table

dqops_client = client.Client(
    'http://localhost:8888/',
    raise_on_unexpected_status=True
)

call_result = await get_table_source_table.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_source_table

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token,
    raise_on_unexpected_status=True
)

call_result = get_table_source_table.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_source_table

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token,
    raise_on_unexpected_status=True
)

call_result = await get_table_source_table.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

get_table_source_tables

Returns a list of source tables on the data lineage that are sources of the given table.

Follow the link to see the source code on GitHub.

GET 

http://localhost:8888/api/connections/{connectionName}/schemas/{schemaName}/tables/{tableName}/lineage/sources

Return value

 Property name   Description                       Data type 
table_lineage_table_list_model List[TableLineageTableListModel]

Parameters of this method are described below

 Property name   Description                       Data type   Required 
connection_name Connection name string
schema_name Schema name string
table_name Table name string
check_type Optional parameter for the check type, when provided, returns the results for data quality dimensions for the data quality checks of that type CheckType

Usage examples

Execution

curl http://localhost:8888/api/connections/sample_connection/schemas/sample_schema/tables/sample_table/lineage/sources^
    -H "Accept: application/json"
Expand to see the returned result 
[ {
  "target_connection" : "datalake",
  "target_schema" : "landing_app",
  "target_table" : "customers_landing",
  "source_connection" : "sourcedb",
  "source_schema" : "app",
  "source_table" : "t_customers",
  "can_edit" : false
}, {
  "target_connection" : "datalake",
  "target_schema" : "landing_app",
  "target_table" : "customers_landing",
  "source_connection" : "sourcedb",
  "source_schema" : "app",
  "source_table" : "t_customers",
  "can_edit" : false
}, {
  "target_connection" : "datalake",
  "target_schema" : "landing_app",
  "target_table" : "customers_landing",
  "source_connection" : "sourcedb",
  "source_schema" : "app",
  "source_table" : "t_customers",
  "can_edit" : false
} ]

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_source_tables
from dqops.client.models import CheckType

dqops_client = client.Client(
    'http://localhost:8888/',
    raise_on_unexpected_status=True
)

call_result = get_table_source_tables.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
[
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    )
]

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_source_tables
from dqops.client.models import CheckType

dqops_client = client.Client(
    'http://localhost:8888/',
    raise_on_unexpected_status=True
)

call_result = await get_table_source_tables.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
[
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    )
]

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_source_tables
from dqops.client.models import CheckType

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token,
    raise_on_unexpected_status=True
)

call_result = get_table_source_tables.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
[
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    )
]

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_source_tables
from dqops.client.models import CheckType

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token,
    raise_on_unexpected_status=True
)

call_result = await get_table_source_tables.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
[
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    )
]

get_table_target_tables

Returns a list of target tables on the data lineage that are downstream tables of the given table.

Follow the link to see the source code on GitHub.

GET 

http://localhost:8888/api/connections/{connectionName}/schemas/{schemaName}/tables/{tableName}/lineage/targets

Return value

 Property name   Description                       Data type 
table_lineage_table_list_model List[TableLineageTableListModel]

Parameters of this method are described below

 Property name   Description                       Data type   Required 
connection_name Connection name string
schema_name Schema name string
table_name Table name string
check_type Optional parameter for the check type, when provided, returns the results for data quality dimensions for the data quality checks of that type CheckType

Usage examples

Execution

curl http://localhost:8888/api/connections/sample_connection/schemas/sample_schema/tables/sample_table/lineage/targets^
    -H "Accept: application/json"
Expand to see the returned result 
[ {
  "target_connection" : "datalake",
  "target_schema" : "landing_app",
  "target_table" : "customers_landing",
  "source_connection" : "sourcedb",
  "source_schema" : "app",
  "source_table" : "t_customers",
  "can_edit" : false
}, {
  "target_connection" : "datalake",
  "target_schema" : "landing_app",
  "target_table" : "customers_landing",
  "source_connection" : "sourcedb",
  "source_schema" : "app",
  "source_table" : "t_customers",
  "can_edit" : false
}, {
  "target_connection" : "datalake",
  "target_schema" : "landing_app",
  "target_table" : "customers_landing",
  "source_connection" : "sourcedb",
  "source_schema" : "app",
  "source_table" : "t_customers",
  "can_edit" : false
} ]

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_target_tables
from dqops.client.models import CheckType

dqops_client = client.Client(
    'http://localhost:8888/',
    raise_on_unexpected_status=True
)

call_result = get_table_target_tables.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
[
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    )
]

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_target_tables
from dqops.client.models import CheckType

dqops_client = client.Client(
    'http://localhost:8888/',
    raise_on_unexpected_status=True
)

call_result = await get_table_target_tables.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
[
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    )
]

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_target_tables
from dqops.client.models import CheckType

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token,
    raise_on_unexpected_status=True
)

call_result = get_table_target_tables.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
[
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    )
]

Execution

from dqops import client
from dqops.client.api.data_lineage import get_table_target_tables
from dqops.client.models import CheckType

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token,
    raise_on_unexpected_status=True
)

call_result = await get_table_target_tables.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client
)
Expand to see the returned result 
[
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    ),
    TableLineageTableListModel(
        target_connection='datalake',
        target_schema='landing_app',
        target_table='customers_landing',
        source_connection='sourcedb',
        source_schema='app',
        source_table='t_customers',
        can_edit=False
    )
]

update_table_source_table

Update a specific data lineage source table using a new model.

Follow the link to see the source code on GitHub.

PUT 

http://localhost:8888/api/connections/{connectionName}/schemas/{schemaName}/tables/{tableName}/lineage/sources/{sourceConnection}/schemas/{sourceSchema}/tables/{sourceTable}

Parameters of this method are described below

 Property name   Description                       Data type   Required 
connection_name Connection name string
schema_name Schema name string
table_name Table name string
source_connection Source connection name string
source_schema Source schema name string
source_table Source table name string

Request body

 Description                       Data type   Required 
Table lineage source list model TableLineageSourceSpec

Usage examples

Execution

curl -X PUT http://localhost:8888/api/connections/sample_connection/schemas/sample_schema/tables/sample_table/lineage/sources/sample_connection/schemas/sample_schema/tables/sample_table^
    -H "Accept: application/json"^
    -H "Content-Type: application/json"^
    -d^
    "{\"source_connection\":\"\",\"source_schema\":\"\",\"source_table\":\"\"}"

Execution

from dqops import client
from dqops.client.api.data_lineage import update_table_source_table
from dqops.client.models import ColumnLineageSourceSpecMap, \
                                TableLineageSourceSpec

dqops_client = client.Client(
    'http://localhost:8888/'
)

request_body = TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

call_result = update_table_source_table.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client,
    json_body=request_body
)

Execution

from dqops import client
from dqops.client.api.data_lineage import update_table_source_table
from dqops.client.models import ColumnLineageSourceSpecMap, \
                                TableLineageSourceSpec

dqops_client = client.Client(
    'http://localhost:8888/'
)

request_body = TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

call_result = await update_table_source_table.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client,
    json_body=request_body
)

Execution

from dqops import client
from dqops.client.api.data_lineage import update_table_source_table
from dqops.client.models import ColumnLineageSourceSpecMap, \
                                TableLineageSourceSpec

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token
)

request_body = TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

call_result = update_table_source_table.sync(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client,
    json_body=request_body
)

Execution

from dqops import client
from dqops.client.api.data_lineage import update_table_source_table
from dqops.client.models import ColumnLineageSourceSpecMap, \
                                TableLineageSourceSpec

token = 's4mp13_4u7h_70k3n'

dqops_client = client.AuthenticatedClient(
    'http://localhost:8888/',
    token=token
)

request_body = TableLineageSourceSpec(
    source_connection='',
    source_schema='',
    source_table='',
    columns=ColumnLineageSourceSpecMap()
)

call_result = await update_table_source_table.asyncio(
    'sample_connection',
    'sample_schema',
    'sample_table',
    'sample_connection',
    'sample_schema',
    'sample_table',
    client=dqops_client,
    json_body=request_body
)