@@ -422,20 +422,16 @@ void CommonConfigProvider::UpdateRemotePipelineConfig(
422
422
filesystem::remove (filePath, ec);
423
423
ConfigFeedbackReceiver::GetInstance ().UnregisterContinuousPipelineConfig (config.name ());
424
424
} else {
425
+ ConfigInfo info;
426
+ info.name = config.name ();
427
+ info.version = config.version ();
428
+ info.detail = config.detail ();
425
429
if (!DumpConfigFile (config, sourceDir)) {
426
- ConfigInfo info;
427
- info.name = config.name ();
428
- info.version = config.version ();
429
430
info.status = ConfigFeedbackStatus::FAILED;
430
- info.detail = config.detail ();
431
431
mContinuousPipelineConfigInfoMap [config.name ()] = std::move (info);
432
432
continue ;
433
433
}
434
- ConfigInfo info;
435
- info.name = config.name ();
436
- info.version = config.version ();
437
434
info.status = ConfigFeedbackStatus::APPLYING;
438
- info.detail = config.detail ();
439
435
mContinuousPipelineConfigInfoMap [config.name ()] = std::move (info);
440
436
ConfigFeedbackReceiver::GetInstance ().RegisterContinuousPipelineConfig (config.name (), this );
441
437
}
@@ -470,20 +466,16 @@ void CommonConfigProvider::UpdateRemoteInstanceConfig(
470
466
filesystem::remove (filePath, ec);
471
467
ConfigFeedbackReceiver::GetInstance ().UnregisterInstanceConfig (config.name ());
472
468
} else {
469
+ ConfigInfo info;
470
+ info.name = config.name ();
471
+ info.version = config.version ();
472
+ info.detail = config.detail ();
473
473
if (!DumpConfigFile (config, sourceDir)) {
474
- ConfigInfo info;
475
- info.name = config.name ();
476
- info.version = config.version ();
477
474
info.status = ConfigFeedbackStatus::FAILED;
478
- info.detail = config.detail ();
479
475
mInstanceConfigInfoMap [config.name ()] = std::move (info);
480
476
continue ;
481
477
}
482
- ConfigInfo info;
483
- info.name = config.name ();
484
- info.version = config.version ();
485
478
info.status = ConfigFeedbackStatus::APPLYING;
486
- info.detail = config.detail ();
487
479
mInstanceConfigInfoMap [config.name ()] = std::move (info);
488
480
ConfigFeedbackReceiver::GetInstance ().RegisterInstanceConfig (config.name (), this );
489
481
}
0 commit comments