We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9af8e5b commit 9f78ee7Copy full SHA for 9f78ee7
1 file changed
delta-plugins-common/src/main/java/io/cdap/delta/plugin/mock/MockContext.java
@@ -19,6 +19,7 @@
19
import io.cdap.cdap.api.macro.MacroEvaluator;
20
import io.cdap.cdap.api.metrics.Metrics;
21
import io.cdap.cdap.api.plugin.PluginProperties;
22
+import io.cdap.delta.api.DeltaPipelineId;
23
import io.cdap.delta.api.DeltaSourceContext;
24
import io.cdap.delta.api.ReplicationError;
25
@@ -109,6 +110,11 @@ public void putState(String s, byte[] bytes) {
109
110
state.put(s, bytes);
111
}
112
113
+ @Override
114
+ public DeltaPipelineId getPipelineId() {
115
+ return new DeltaPipelineId("default", "app", 0L);
116
+ }
117
+
118
@Override
119
public PluginProperties getPluginProperties(String pluginId) {
120
return PluginProperties.builder().build();
0 commit comments