res = client.transformations.run(transformation_id = 1)
res = client.transformations.run(transformation_id = 1, wait = False)
import asyncio
async def run_transformation():
res = await client.transformations.run_async(id = 1)
loop = asyncio.get_event_loop()
loop.run_until_complete(run_transformation())
loop.close(){
"id": 123,
"uuid": "<string>",
"transformationId": 123,
"transformationExternalId": "<string>",
"sourceProject": "<string>",
"destinationProject": "<string>",
"destination": {
"type": "assets"
},
"conflictMode": "abort",
"query": "<string>",
"createdTime": 123,
"ignoreNullFields": true,
"status": "Completed",
"startedTime": 123,
"finishedTime": 123,
"lastSeenTime": 123,
"error": "<string>"
}Run a transformation
Required capabilities:
transformationsAcl:WRITE
res = client.transformations.run(transformation_id = 1)
res = client.transformations.run(transformation_id = 1, wait = False)
import asyncio
async def run_transformation():
res = await client.transformations.run_async(id = 1)
loop = asyncio.get_event_loop()
loop.run_until_complete(run_transformation())
loop.close(){
"id": 123,
"uuid": "<string>",
"transformationId": 123,
"transformationExternalId": "<string>",
"sourceProject": "<string>",
"destinationProject": "<string>",
"destination": {
"type": "assets"
},
"conflictMode": "abort",
"query": "<string>",
"createdTime": 123,
"ignoreNullFields": true,
"status": "Completed",
"startedTime": 123,
"finishedTime": 123,
"lastSeenTime": 123,
"error": "<string>"
}Authorizations
Access token issued by the CDF project's configured identity provider. Access token must be an OpenID Connect token, and the project must be configured to accept OpenID Connect tokens. Use a header key of 'Authorization' with a value of 'Bearer $accesstoken'. The token can be obtained through any flow supported by the identity provider.
Body
- Option 1
- Option 2
The external ID provided by the client. Must be unique for the resource type.
255"my.known.id"
Credentials for a CDF session (sessionId, nonce, and project name). These are obtained when you create a session via the Sessions API. See Sessions API documentation for more information.
Show child attributes
Show child attributes
Response
Response with a single job.
Details for the last finished job of this transformation
Job numeric ID.
UUID id of the job.
ID of the transformation that created this job.
External ID of the transformation that created this job.
CDF project which is used as source for reading data.
CDF project which is used as destination for writing data.
Destination data type.
- Option 1
- Option 2
- Option 3
- Option 4
- Option 5
Show child attributes
Show child attributes
Behavior when the data already exists.upsert - Create or Update,abort - Create and fail when already exists,update - update and fail if it does not exist,delete - delete the matched rows.
abort, delete, update, upsert The SQL query being executed.
Time when the job was created: The number of milliseconds since 00:00:00 Thursday, 1 January 1970, Coordinated Universal Time (UTC), minus leap seconds.
How NULL values are handled on updates: ignore or setNull.
Status of the job at the request time.
Completed, Created, Failed, Running Time when this job started executing: The number of milliseconds since 00:00:00 Thursday, 1 January 1970, Coordinated Universal Time (UTC), minus leap seconds.
Time when this job finished running: The number of milliseconds since 00:00:00 Thursday, 1 January 1970, Coordinated Universal Time (UTC), minus leap seconds.
Time when this job last registered running: The number of milliseconds since 00:00:00 Thursday, 1 January 1970, Coordinated Universal Time (UTC), minus leap seconds.
If the job failed, this will be a string describing why. When null, the job did not fail.
Was this page helpful?