Skip to main content

In catalog item DQ evaluation, we are trying to run the DQ evaluation via API and it is working fine. Do we have an API to load the failed records to ONE data via API?

 

@Hanish N this mutation will both trigger a DQ evaluation job and load the results into ONE Data:

mutation ImportCatalogItemDq($dmmEntity: DmmDqEntityInput!, $catalogItemId: GID!, $dqFilter: DmmDqFilter!, $importStrategy: DmmDqImportStrategy!) {
dmmImportCatalogItemDQ(
dmmEntity: $dmmEntity
catalogItemId: $catalogItemId
dqFilter: $dqFilter
importStrategy: $importStrategy
) {
dqJobState {
reason
gid
executionType
name
entityId
type
status
__typename
}
dmmDqJobError {
errorCode
__typename
}
__typename
}
}

Assuming you always load to an existing ONE Data table, the variables might look like this:

{
"dmmEntity": {
"name": "target_ONE_Data_table(invalid records)",
"description": "",
"id": "a0b74cd0-7301-4396-b2b2-4dca571f7eec",
"stewardshipGroup": null
},
"catalogItemId": "15bbce34-0000-7000-0000-0000001a0228",
"dqFilter": "INVALID",
"importStrategy": "OVERWRITE"
}

Let me know if you have any additional questions!


Reply