Payload used:
2022-09-24 164054.170 DEBUG 18568 --- [http-nio-5080-exec-962] com.aops.waves.service.FlowService : jsonObject.toJSONString():
{
"parameter_openapi_schema": {
"type": "object",
"title": "Parameters",
"properties": {
"kwargs": "{\"type\": \"string\", \"title\":\"kwargs\"}"
},
"required": [
"kwargs"
]
},
"infrastructure_document_id": "736c6e6f-6c03-40fa-8ea4-71f946a05343",
"infra_overrides": {},
"description": "AOPS_SQL_Workflow_DS_12",
"version": "1",
"work_queue_name": "waves_q",
"tags": [
"waves_q"
],
"path": "/localpart0/aop-shared/WAVES/workflows/",
"schedule": {
"rrule": "DTSTART20220924T124300\nRRULEFREQ=HOURLY;INTERVAL=1;COUNT=1;UNTIL=20220924T124500",
"timezone": "US/Eastern"
},
"flow_id": "d7202f6b-b929-4139-9e4d-73e2636a3fe0",
"entrypoint": "AOPS_SQL_Workflow_v1.py:AOPS_SQL_Workflow",
"name": "AOPS_SQL_Workflow_DS_12",
"parameters": {
"kwargs": {
"sqltype": 1,
"date_range": "CURRENT_DATE - INTERVAL '1 months'",
"dbname": "gpprod",
"selection": "count(*)",
"flow_name": "AOPS_SQL_Workflow",
"rpt_flag": "1",
"tab1": "whse.dim_company",
"schd_run_name": "AOPS_SQL_Workflow_DS_12",
"sql": "SELECT {selection} FROM {tab1} WHERE show_in_report_flag = {rpt_flag} and (creation_date > ({date_range}));"
}
},
API Response:
{
"id": "ba109826-6846-4e0e-815b-ee905c593dab",
"created": "2022-09-23T194943.563714+00:00",
"updated": "2022-09-24T164054.208488+00:00",
"name": "AOPS_SQL_Workflow_DS_12",
"version": "1",
"description": "AOPS_SQL_Workflow_DS_12",
"flow_id": "d7202f6b-b929-4139-9e4d-73e2636a3fe0",
"schedule": {
"rrule": "DTSTART20220924T124300\nRRULEFREQ=HOURLY;INTERVAL=1;COUNT=1;UNTIL=20220924T124500",
"timezone": "US/Eastern"
},
"is_schedule_active": true,
"infra_overrides": {},
"parameters": {
"kwargs": {
"sql": "SELECT {selection} FROM {tab1} WHERE show_in_report_flag = {rpt_flag} and (creation_date > ({date_range}));",
"tab1": "whse.dim_company",
"dbname": "gpprod",
"sqltype": 1,
"rpt_flag": "1",
"flow_name": "AOPS_SQL_Workflow",
"selection": "count(*)",
"date_range": "CURRENT_DATE - INTERVAL '1 months'",
"schd_run_name": "AOPS_SQL_Workflow_DS_12"
}
},
"tags": [
"waves_q"
],
"work_queue_name": "waves_q",
"parameter_openapi_schema": {
"type": "object",
"title": "Parameters",
"required": [
"kwargs"
],
"properties": {
"kwargs": "{\"type\": \"string\", \"title\":\"kwargs\"}"
}
},
"path": "/localpart0/aop-shared/WAVES/workflows/",
"entrypoint": "AOPS_SQL_Workflow_v1.py:AOPS_SQL_Workflow",
"manifest_path": null,
"storage_document_id": null,
"infrastructure_document_id": "736c6e6f-6c03-40fa-8ea4-71f946a05343"
}
"is_schedule_active": "true"
}