summaryrefslogtreecommitdiffstats
path: root/common/pipeline.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2015-05-01 23:50:48 +0200
committerChristian Mollekopf <chrigi_1@fastmail.fm>2015-05-01 23:50:48 +0200
commitad4d727f198a3088f1c967f6373306d1cb100d72 (patch)
tree4553152a4512ced9660be6f9f1c7df5c22c6d6b7 /common/pipeline.cpp
parent4bbb92fd179fc00258264bd488270179ff246510 (diff)
downloadsink-ad4d727f198a3088f1c967f6373306d1cb100d72.tar.gz
sink-ad4d727f198a3088f1c967f6373306d1cb100d72.zip
Error handling
Diffstat (limited to 'common/pipeline.cpp')
-rw-r--r--common/pipeline.cpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/common/pipeline.cpp b/common/pipeline.cpp
index ed40699..e2f23ed 100644
--- a/common/pipeline.cpp
+++ b/common/pipeline.cpp
@@ -293,6 +293,9 @@ void PipelineState::step()
293 auto entity = Akonadi2::GetEntity(dataValue); 293 auto entity = Akonadi2::GetEntity(dataValue);
294 preprocessor->process(*this, *entity); 294 preprocessor->process(*this, *entity);
295 return false; 295 return false;
296 }, [this](const Akonadi2::Storage::Error &error) {
297 ErrorMsg() << "Failed to find value in pipeline: " << error.message;
298 d->pipeline->pipelineCompleted(*this);
296 }); 299 });
297 } else { 300 } else {
298 //This object becomes invalid after this call 301 //This object becomes invalid after this call