File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2525#include < Framework/DataProcessorSpec.h>
2626#include < Framework/CompletionPolicy.h>
2727#include < Framework/EndOfStreamContext.h>
28+ #include < Framework/InputSpan.h>
2829#include < Headers/DataHeader.h>
2930#include < Framework/InitContext.h>
3031// QC
@@ -82,7 +83,7 @@ class TaskRunner : public framework::Task
8283 void run (framework::ProcessingContext& pCtx) override ;
8384
8485 // / \brief TaskRunner's completion policy callback
85- static framework::CompletionPolicy::CompletionOp completionPolicyCallback (o2::framework::CompletionPolicy::InputSet inputs);
86+ static framework::CompletionPolicy::CompletionOp completionPolicyCallback (o2::framework::InputSpan const & inputs);
8687
8788 std::string getDeviceName () { return mDeviceName ; };
8889 const framework::Inputs& getInputsSpecs () { return mInputSpecs ; };
Original file line number Diff line number Diff line change 3030#include < Framework/DataSpecUtils.h>
3131#include < Framework/DataDescriptorQueryBuilder.h>
3232#include < Framework/InputRecordWalker.h>
33+ #include < Framework/InputSpan.h>
34+ #include < Framework/RawDeviceService.h>
35+
36+ #include < fairlogger/Logger.h>
37+ #include < FairMQDevice.h>
3338
3439#include " QualityControl/QcInfoLogger.h"
3540#include " QualityControl/TaskFactory.h"
@@ -152,7 +157,7 @@ void TaskRunner::run(ProcessingContext& pCtx)
152157 }
153158}
154159
155- CompletionPolicy::CompletionOp TaskRunner::completionPolicyCallback (o2::framework::CompletionPolicy::InputSet inputs)
160+ CompletionPolicy::CompletionOp TaskRunner::completionPolicyCallback (o2::framework::InputSpan const & inputs)
156161{
157162 // fixme: we assume that there is one timer input and the rest are data inputs. If some other implicit inputs are
158163 // added, this will break.
You can’t perform that action at this time.
0 commit comments