ducktape: fix data_policy ducktape test

Author: VadimPlh

tests/rptest/tests/data_policy_scripts/simple.js

@@ -0,0 +1 @@
+function foo() {}

tests/rptest/tests/data_policy_test.py

@@ -7,28 +7,42 @@
 # the Business Source License, use of this software will be governed
 # by the Apache License, Version 2.0
 
+import os
+
 from ducktape.mark.resource import cluster
 from rptest.clients.kafka_cli_tools import KafkaCliTools
 from rptest.clients.types import TopicSpec
 
 import subprocess
 
 from rptest.tests.redpanda_test import RedpandaTest
+from rptest.clients.rpk import RpkTool
 
 
 class DataPolicyTest(RedpandaTest):
     topics = (TopicSpec(partition_count=1, replication_factor=3), )
 
     def __init__(self, test_context):
+        extra_rp_conf = dict(
+            developer_mode=True,
+            enable_v8=True,
+        )
         super(DataPolicyTest, self).__init__(test_context=test_context,
-                                             num_brokers=3)
+                                             num_brokers=3,
+                                             extra_rp_conf=extra_rp_conf)
 
         self.kafka_tools = KafkaCliTools(self.redpanda)
+        self.rpk = RpkTool(self.redpanda)
 
     def _get_data_policy(self, function_name, script_name):
         return "function_name: {} script_name: {}".format(
             function_name, script_name)
 
+    def _deploy_script(self, script_name, path):
+        current_dir = os.path.dirname(os.path.realpath(__file__))
+        file_path = os.path.join(current_dir, "data_policy_scripts", path)
+        self.rpk.wasm_deploy(file_path, script_name, "", "data-policy")
+
     @cluster(num_nodes=3)
     def test_default_data_policy(self):
         topic = self.topics[0].name
@@ -38,6 +52,7 @@ def test_default_data_policy(self):
 
     @cluster(num_nodes=3)
     def test_set_data_policy(self):
+        self._deploy_script("2", "simple.js")
         topic = self.topics[0].name
         kafka_tools = KafkaCliTools(self.redpanda)
         res = kafka_tools.alter_topic_config(
@@ -50,6 +65,7 @@ def test_set_data_policy(self):
 
     @cluster(num_nodes=3)
     def test_incremental_config(self):
+        self._deploy_script("2", "simple.js")
         topic = self.topics[0].name
         kafka_tools = KafkaCliTools(self.redpanda)
         kafka_tools.alter_topic_config(