From e8bd1c8b8d1265412b9cabf659bb5dbe119e32c0 Mon Sep 17 00:00:00 2001
From: Marius van den Beek <m.vandenbeek@gmail.com>
Date: Thu, 14 Apr 2016 19:41:13 +0200
Subject: [PATCH] Fix typo and duplicate line
---
pulsar/managers/staging/post.py | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/pulsar/managers/staging/post.py b/pulsar/managers/staging/post.py
index 060dcb05..4edf8e4f 100644
--- a/pulsar/managers/staging/post.py
+++ b/pulsar/managers/staging/post.py
@@ -12,7 +12,7 @@ log = logging.getLogger(__name__)
def postprocess(job_directory, action_executor):
- # Returns True iff outputs were collected.
+ # Returns True if outputs were collected.
try:
staging_config = job_directory.load_metadata("staging_config", None)
collected = __collect_outputs(job_directory, staging_config, action_executor)
@@ -30,7 +30,6 @@ def __collect_outputs(job_directory, staging_config, action_executor):
pulsar_outputs = __pulsar_outputs(job_directory)
output_collector = PulsarServerOutputCollector(job_directory, action_executor)
results_collector = ResultsCollector(output_collector, file_action_mapper, client_outputs, pulsar_outputs)
- results_collector = ResultsCollector(output_collector, file_action_mapper, client_outputs, pulsar_outputs)
collection_failure_exceptions = results_collector.collect()
if collection_failure_exceptions:
log.warn("Failures collecting results %s" % collection_failure_exceptions)
--
GitLab