28 JetScapeTask::JetScapeTask() {
31 my_task_number_ = JetScapeTaskSupport::Instance()->RegisterTask();
35 JetScapeTask::~JetScapeTask() {
37 JSDEBUG <<
"Deleting task with id=" << GetId()
38 <<
" and TaskNumber= " << GetMyTaskNumber();
45 void JetScapeTask::InitTasks() {
46 VERBOSE(7) <<
" : # Subtasks = " << tasks.size();
55 void JetScapeTask::ExecuteTasks() {
56 VERBOSE(7) <<
" : # Subtasks = " << tasks.size();
57 for (
auto it : tasks) {
58 if (
it->active_exec) {
65 void JetScapeTask::ClearTasks() {
66 VERBOSE(7) <<
" : # Subtasks = " << tasks.size();
72 void JetScapeTask::WriteTasks(weak_ptr<JetScapeWriter> w) {
80 void JetScapeTask::CollectHeaders(weak_ptr<JetScapeWriter> w) {
89 tasks.push_back(m_tasks);