Skip to content

Commit

Permalink
DPL: mark dummy sink as resilient to expendable task failures
Browse files Browse the repository at this point in the history
  • Loading branch information
ktf committed Nov 29, 2023
1 parent 6cc46bd commit ad03088
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions Framework/Core/src/CommonDataProcessors.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -599,9 +599,8 @@ DataProcessorSpec CommonDataProcessors::getDummySink(std::vector<InputSpec> cons
.options = !rateLimitingChannelConfig.empty() ? std::vector<ConfigParamSpec>{{"channel-config", VariantType::String, // raw input channel
rateLimitingChannelConfig,
{"Out-of-band channel config"}}}
: std::vector<ConfigParamSpec>()

};
: std::vector<ConfigParamSpec>(),
.labels = {{"resilient"}}};
}

AlgorithmSpec CommonDataProcessors::wrapWithRateLimiting(AlgorithmSpec spec)
Expand Down

0 comments on commit ad03088

Please sign in to comment.