lib/embulk/output/bigquery.rb in embulk-output-bigquery-0.3.0.pre6 vs lib/embulk/output/bigquery.rb in embulk-output-bigquery-0.3.0
- old
+ new
@@ -10,11 +10,11 @@
class Bigquery < OutputPlugin
Plugin.register_output('bigquery', self)
class Error < StandardError; end
- # To support configuration like below as org.embulk.spi.unit.LoalFile
+ # To support configuration like below as org.embulk.spi.unit.LocalFile
#
# json_keyfile:
# content: |
class LocalFile
# @return JSON string
@@ -319,16 +319,16 @@
bigquery.delete_table(task['temp_table'])
end
ensure
if task['delete_from_local_when_job_end']
paths.each do |path|
- Embulk.logger.info { "delete #{path}" }
+ Embulk.logger.info { "embulk-output-bigquery: delete #{path}" }
File.unlink(path) rescue nil
end
else
paths.each do |path|
if File.exist?(path)
- Embulk.logger.info { "#{path} is left" }
+ Embulk.logger.info { "embulk-output-bigquery: keep #{path}" }
end
end
end
end
end