From f10d17ab1fc4b082701ebc94432431853c0edd03 Mon Sep 17 00:00:00 2001 From: Oren Leiman Date: Mon, 24 Jun 2024 13:59:41 -0700 Subject: [PATCH] dt/rpk: Add offset parameter to deploy_wasm Signed-off-by: Oren Leiman --- tests/rptest/clients/rpk.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/tests/rptest/clients/rpk.py b/tests/rptest/clients/rpk.py index 0ece0fc0aabd7..338c48319d4bf 100644 --- a/tests/rptest/clients/rpk.py +++ b/tests/rptest/clients/rpk.py @@ -1709,13 +1709,16 @@ def deploy_wasm(self, output_topics, file="tinygo/identity.wasm", compression_type: TopicSpec.CompressionTypes - | None = None): + | None = None, + from_offset: str | None = None): cmd = [ "deploy", "--name", name, "--input-topic", input_topic, "--file", f"/opt/transforms/{file}" ] if compression_type is not None: cmd += ["--compression", compression_type] + if from_offset is not None: + cmd += ["--from-offset", from_offset] assert len(output_topics) > 0, "missing output topics" for topic in output_topics: cmd += ["--output-topic", topic]