|
|
@@ -112,8 +112,8 @@ def datax_put_task(job_info: models.JobInfo,old_af_task):
|
|
|
"current_key": current_key,
|
|
|
"partition_key": "partition",
|
|
|
"partition_word": partition_list[0] if len(partition_list) > 0 else 'xujiayue',
|
|
|
- "partition_format": partition_list[2] if len(partition_list) > 0 else 'xujiayue',
|
|
|
- "partition_diff": partition_list[1] if len(partition_list) > 0 else 'xujiayue'
|
|
|
+ "partition_format": partition_list[2] if len(partition_list) > 0 else '%Y-%m-%d',
|
|
|
+ "partition_diff": partition_list[1] if len(partition_list) > 0 else None
|
|
|
}
|
|
|
af_task = {
|
|
|
"name": job_info.job_desc,
|
