src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java in embulk-input-riak_cs-0.2.4 vs src/test/java/org/embulk/input/riak_cs/TestRiakCsFileInputPlugin.java in embulk-input-riak_cs-0.2.5
- old
+ new
@@ -1,11 +1,10 @@
package org.embulk.input.riak_cs;
import org.embulk.EmbulkTestRuntime;
import org.embulk.config.ConfigSource;
import org.embulk.input.s3.AbstractS3FileInputPlugin.PluginTask;
-import org.embulk.input.s3.TestS3FileInputPlugin;
import org.junit.Before;
import org.junit.Rule;
import org.junit.Test;
public class TestRiakCsFileInputPlugin
@@ -23,10 +22,15 @@
}
@Test
public void createS3ClientSuccessfully()
{
- ConfigSource config = TestS3FileInputPlugin.config().set("endpoint", "my.endpoint.com");
+ ConfigSource config = runtime.getExec().newConfigSource()
+ .set("endpoint", "my.endpoint.com")
+ .set("bucket", "my_bucket")
+ .set("path_prefix", "my_path_prefix")
+ .set("access_key_id", "my_access_key_id")
+ .set("secret_access_key", "my_secret_access_key");
PluginTask task = config.loadConfig(plugin.getTaskClass());
plugin.newS3Client(task);
}
}