Pay load updated

frontend/src/components/ui/DeployedPipelineActions.jsx

@@ -12,14 +12,14 @@
 import { getScheme } from "@/client/anvil";
 
 export const DeployedPipelineActions = ({
   name,
   uuid,
   hash,
   configuration,
   pipelineData,
 }) => {
   const [isModalOpen, setIsModalOpen] = useState(false);
   const [activeTab, setActiveTab] = useState("js");
   const [codePayload, setCodePayload] = useState({
     jsCode: "",
     pythonCode: "",
@@ -27,7 +27,7 @@
 
   const generatePostPayload = () => {
     const inputs = {};
     Object.entries(pipelineData.pipeline).forEach(([nodeId, node]) => {
       if (node.inputs) {
         Object.entries(node.inputs).forEach(([inputName, input]) => {
           if (input.connections && input.connections.length > 0) {
@@ -50,10 +50,19 @@
 
     const pythonCode = `from zetaforge import Zetaforge
 
-zetaforge = Zetaforge(address='${getScheme(configuration.anvil.host)}://${configuration.anvil.host}:${configuration.anvil.port}', token='${configuration.anvil.token}')
+    # Create an instance of the Zetaforge class
+zetaforge = Zetaforge(base_url='${getScheme(configuration.anvil.host)}://${configuration.anvil.host}:${configuration.anvil.port}', token='${configuration.anvil.token}')
 
-result = zetaforge.run('${name}:${hash.substring(0, 8)}', input=${JSON.stringify(inputs, null, 2)})
-print('Pipeline execution result:', result)
+pipelineUuid = "${uuid}"
+pipelineHash = "${hash}"
+inputs = ${JSON.stringify(inputs, null, 2)}
+
+try: 
+  execute_response = zetaforge.run(pipelineUuid, pipelineHash, inputs)
+  print('Pipeline execution result:', execute_response)
+
+except Exception as error:
+  print('Failed to execute pipeline:', str(error))
 `;
 
     const jsCode = `import Zetaforge from "zetaforge";
@@ -84,7 +93,7 @@
 
   const handleClose = () => setIsModalOpen(false);
 
   const handleUndeploy = () => {
     console.log("Undeploying pipeline:", uuid);
   };