Commit 4b255adb authored by Eteri's avatar Eteri

fix encode decode

parent ae5730ef
...@@ -107,7 +107,7 @@ module Embulk ...@@ -107,7 +107,7 @@ module Embulk
else else
@reference = [supplier, dataset, filename, extension, eof, size, hash].join(DatasetUtils::REFERENCE_SEPARATOR) @reference = [supplier, dataset, filename, extension, eof, size, hash].join(DatasetUtils::REFERENCE_SEPARATOR)
split = eof != "" split = eof != ""
ingestion_response = @wendelin.ingest(@reference, data_chunk, split) ingestion_response = @wendelin.ingest(@reference, Base64.decode64(data_chunk), split)
if not ingestion_response["success"] if not ingestion_response["success"]
raise ingestion_response["message"] raise ingestion_response["message"]
end end
......
...@@ -17,7 +17,7 @@ class WendelinClient ...@@ -17,7 +17,7 @@ class WendelinClient
HTTP_MEMORY_ERROR = "MEMORY-ERROR" HTTP_MEMORY_ERROR = "MEMORY-ERROR"
HTTP_REFERENCE_EXIST = "REFERENCE-EXIST" HTTP_REFERENCE_EXIST = "REFERENCE-EXIST"
def initialize(erp5_url, user, password, tag, extension) def initialize(erp5_url, user, password, tag=nil, extension=nil)
@erp5_url = erp5_url @erp5_url = erp5_url
@user = user @user = user
@password = password @password = password
......
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