Commit 1a5f1751 authored by Eteri's avatar Eteri

fix tag passing

remove dummy logs
parent 4b255adb
...@@ -29,7 +29,7 @@ module Embulk ...@@ -29,7 +29,7 @@ module Embulk
@dataset_utils.setDatasetDescription(task["data_set"], task["tool_dir"], @wendelin) if @new_dataset_description @dataset_utils.setDatasetDescription(task["data_set"], task["tool_dir"], @wendelin) if @new_dataset_description
end end
task_reports = yield(task) task_reports = yield(task)
next_config_diff = {} next_config_diff = {}
if task_reports.length > 0 if task_reports.length > 0
@logger.info("Your ingested files will be available in the site in a few minutes. Thank for your patience.", print=TRUE) @logger.info("Your ingested files will be available in the site in a few minutes. Thank for your patience.", print=TRUE)
if storage_ingestion if storage_ingestion
...@@ -39,7 +39,11 @@ module Embulk ...@@ -39,7 +39,11 @@ module Embulk
if(done_tasks.length == count) if(done_tasks.length == count)
@logger.info("Dataset successfully ingested.", print=TRUE) @logger.info("Dataset successfully ingested.", print=TRUE)
@wendelin = WendelinClient.new(task["erp5_base_url"], task["user"], task["password"], task["tag"], task["extension"]) @wendelin = WendelinClient.new(task["erp5_base_url"], task["user"], task["password"], task["tag"], task["extension"])
@wendelin.increaseDatasetVersion(task["data_set"]) if task["tag"] != nil
@wendelin.increaseDatasetVersion(task["tag"])
else
@wendelin.increaseDatasetVersion(task["data_set"])
end
else else
failed_tasks = task_reports.map{|hash| hash[DatasetUtils::RUN_ERROR] || hash[DatasetUtils::RUN_ABORTED] }.flatten.compact failed_tasks = task_reports.map{|hash| hash[DatasetUtils::RUN_ERROR] || hash[DatasetUtils::RUN_ABORTED] }.flatten.compact
@dataset_utils.showTaskErrors(failed_tasks, storage=TRUE) @dataset_utils.showTaskErrors(failed_tasks, storage=TRUE)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment