Browse Source

分区字段增加默认值

liweiquan 2 years ago
parent
commit
c49631c3fd
1 changed files with 3 additions and 3 deletions
  1. 3 3
      app/services/datax.py

+ 3 - 3
app/services/datax.py

@@ -48,9 +48,9 @@ def datax_create_task(job_info: models.JobInfo):
             "last_key": last_key,
             "current_key": current_key,
             "partition_key": "partition",
-            "partition_word": partition_list[0] if len(partition_list) > 0 else '',
-            "partition_format": partition_list[2]  if len(partition_list) > 0 else '',
-            "partition_diff": partition_list[1]  if len(partition_list) > 0 else ''
+            "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'
         }
     af_task = {
         "name": job_info.job_desc,