File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 3333#include " Framework/ServiceRegistryRef.h"
3434#include " Framework/ServiceRegistryHelpers.h"
3535#include " Framework/Signpost.h"
36+ #include " Framework/DefaultsHelpers.h"
3637
3738#include " CommonMessageBackendsHelpers.h"
3839#include < Monitoring/Monitoring.h>
@@ -65,7 +66,7 @@ enum struct RateLimitingState {
6566
6667struct RateLimitConfig {
6768 int64_t maxMemory = 2000 ;
68- int64_t maxTimeframes = 1 ;
69+ int64_t maxTimeframes = 1000 ;
6970};
7071
7172struct MetricIndices {
@@ -524,7 +525,7 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec()
524525 if (dc.options .count (" timeframes-rate-limit" ) && dc.options [" timeframes-rate-limit" ].defaulted () == false ) {
525526 config->maxTimeframes = std::stoll (dc.options [" timeframes-rate-limit" ].as <std::string>());
526527 } else {
527- config->maxTimeframes = readers;
528+ config->maxTimeframes = readers * DefaultsHelpers::pipelineLength () ;
528529 }
529530 static bool once = false ;
530531 // Until we guarantee this is called only once...
You can’t perform that action at this time.
0 commit comments