diff --git a/frontend/src/views/AngularWorkflow.jsx b/frontend/src/views/AngularWorkflow.jsx index 5bb4adb7..4357229e 100755 --- a/frontend/src/views/AngularWorkflow.jsx +++ b/frontend/src/views/AngularWorkflow.jsx @@ -1362,7 +1362,7 @@ const AngularWorkflow = (defaultprops) => { const topic = document.getElementById('topic')?.value; const bootstrapServers = document.getElementById('bootstrap_servers')?.value; const groupId = document.getElementById('group_id')?.value; - const autoOffsetReset = document.getElementById('auto_offset_reset')?.value; + //const autoOffsetReset = document.getElementById('auto_offset_reset')?.value; if(topic) { trigger.parameters.push({ @@ -1391,12 +1391,12 @@ const AngularWorkflow = (defaultprops) => { }); } - if (autoOffsetReset) { - trigger.parameters.push({ - name: "auto_offset_reset", - value: autoOffsetReset - }); - } + // if (autoOffsetReset) { + // trigger.parameters.push({ + // name: "auto_offset_reset", + // value: autoOffsetReset + // }); + // } setTenzirConfigModalOpen(false); }; @@ -7488,12 +7488,6 @@ const AngularWorkflow = (defaultprops) => { const data = usecase; data.start_node = mappedStartnode - if (data.type === "create") { - toast("Creating pipeline"); - } else if (data.type === "stop") { - toast("stopping pipeline"); - } - const url = `${globalUrl}/api/v1/triggers/pipeline`; fetch(url, { method: "POST", @@ -7512,12 +7506,8 @@ const AngularWorkflow = (defaultprops) => { return response.json(); }) .then((responseJson) => { - if (!responseJson.success) { - if (responseJson.reason !== undefined) { - toast("Failed to set pipeline: " + responseJson.reason); - } else { - toast.error("Failed to stop pipeline") - } + if (!responseJson.success && data.type !== "delete") { + toast("Failed to set pipeline: " + responseJson.reason); } else { if (data.type === "create") { toast("Pipeline will be created!"); @@ -8026,7 +8016,7 @@ const AngularWorkflow = (defaultprops) => { /* if (trigger.trigger_type === "PIPELINE") { if (userdata.support !== true) { - return null + return null } } */ @@ -9059,7 +9049,7 @@ const AngularWorkflow = (defaultprops) => { return null } - if (app.trigger_type === "PIPELINE" && userdata.support !== true) { + if (globalUrl.includes("shuffler.io") && app.trigger_type === "PIPELINE" && userdata.support !== true) { return null } @@ -14183,7 +14173,7 @@ const AngularWorkflow = (defaultprops) => { return null } - const PipelineSidebar = Object.getOwnPropertyNames(selectedTrigger).length === 0 || workflow.triggers[selectedTriggerIndex] === undefined && selectedTrigger.trigger_type !== "SCHEDULE" ? null : !userdata.support === true ? null : + const PipelineSidebar = Object.getOwnPropertyNames(selectedTrigger).length === 0 || workflow.triggers[selectedTriggerIndex] === undefined && selectedTrigger.trigger_type !== "SCHEDULE" ? null : !userdata.support === true && globalUrl.includes("shuffler.io") ? null :