TANG JIANG 1 year ago
parent
commit
c362d8f43b
1 changed files with 2 additions and 2 deletions
  1. 2 2
      src/DataSharing/SendTask/TaskExecuteJob.cs

+ 2 - 2
src/DataSharing/SendTask/TaskExecuteJob.cs

@@ -33,7 +33,7 @@ namespace DataSharing.SendTask
             var task = await _queue.DequeueAsync<DsSendTask>(SendTaskDefaults.SendTaskQueue, context.CancellationToken);
             if (task is not null)
             {
-                //    if (task.PlatformSource == Share.Enums.EPlatformSource.CityDataExchange)
+                    if (task.PlatformSource == Share.Enums.EPlatformSource.CityDataExchange)
                 await _sendTaskDataService.SendTask(task, context.CancellationToken);
                 _logger.LogInformation($"send task execute, taskId: {task.Id}");
             }
@@ -44,7 +44,7 @@ namespace DataSharing.SendTask
         /// </summary>
         public void Dispose()
         {
-            _logger.LogInformation($"execute job disposing");
+            //_logger.LogInformation($"execute job disposing");
         }
     }
 }