同上

app/services/datax.py

@@ -49,7 +49,7 @@ def datax_create_task(job_info: models.JobInfo):
             "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 '%Y-%m-%d',
-            "partition_diff": partition_list[1]  if len(partition_list) > 0 else None
+            "partition_diff": partition_list[1]  if len(partition_list) > 0 else 0
         }
     af_task = {
         "name": job_info.job_desc,
@@ -113,7 +113,7 @@ def datax_put_task(job_info: models.JobInfo,old_af_task):
             "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 '%Y-%m-%d',
-            "partition_diff": partition_list[1]  if len(partition_list) > 0 else None
+            "partition_diff": partition_list[1]  if len(partition_list) > 0 else 0
         }
     af_task = {
         "name": job_info.job_desc,