GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-26 09:39:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

remove useless series context

Browse Source
This commit is contained in:
wangzhulei
2020-11-19 18:38:28 +08:00
parent c10701af69
commit e360adcb21
1 changed files with 0 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/WFKafkaClient.cc
-2
View File
@@ -796,7 +796,6 @@ void ComplexKafkaTask::dispatch()
KafkaComplexTask *ctask = static_cast<KafkaComplexTask *>(task);
*ctask->get_mutable_ctx() = cb;
series = Workflow::create_series_work(task, nullptr);
series->set_context(task);
parallel->add_series(series);
}
series_of(this)->push_front(this);
@@ -847,7 +846,6 @@ void ComplexKafkaTask::dispatch()
KafkaComplexTask *ctask = static_cast<KafkaComplexTask *>(task);
*ctask->get_mutable_ctx() = cb;
series = Workflow::create_series_work(task, nullptr);
series->set_context(task);
parallel->add_series(series);
}