We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b1904ff commit c6a01d6Copy full SHA for c6a01d6
Framework/Core/src/ArrowSupport.cxx
@@ -284,10 +284,10 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec()
284
unchangedCount++;
285
}
286
changedCountMetric(driverMetrics, unchangedCount, timestamp);
287
- auto maxTimeframes = registry.get<RateLimitConfig>().maxTimeframes;
288
- if (maxTimeframes && (totalTimeframesRead - totalTimeframesConsumed) > maxTimeframes) {
289
- return;
290
- }
+ //auto maxTimeframes = registry.get<RateLimitConfig>().maxTimeframes;
+ //if (maxTimeframes && (totalTimeframesRead - totalTimeframesConsumed) > maxTimeframes) {
+ // return;
+ //}
291
292
static int64_t MAX_SHARED_MEMORY = calculateAvailableSharedMemory(registry);
293
constexpr int64_t MAX_QUANTUM_SHARED_MEMORY = 100;
0 commit comments