Merge pull request #533 from zenml-io/dev

refactor: remove polling from dag visualizer (#532)

Author: Cahllagerfeld

src/ui/layouts/pipelines/RunDetail/useService.ts

@@ -51,33 +51,6 @@ export const useService = (): ServiceInterface => {
     // eslint-disable-next-line react-hooks/exhaustive-deps
   }, [isMounted, setIsMounted]);
 
-  useEffect(() => {
-    if (run.body?.status === 'running') {
-      const intervalId = setInterval(() => {
-        dispatch(
-          runsActions.runForId({
-            pipelineId: pipelineId,
-            runId: id,
-            onSuccess: (res) => {
-              if (res.status !== 'running') {
-                dispatch(
-                  runsActions.graphForRun({
-                    runId: id,
-                  }),
-                );
-              }
-            },
-          }),
-        );
-      }, 12000);
-
-      return () => {
-        clearInterval(intervalId);
-      };
-    }
-    // This is important
-  }, [pipelineId, id, run, dispatch]);
-
   const fetchMetaData = async () => {
     const response = await axios.get(
       `${process.env.REACT_APP_BASE_API_URL}/run-metadata?pipeline_run_id=${id}&key=orchestrator_url`,

src/ui/layouts/repositories/RunDetail/useService.ts

@@ -51,33 +51,6 @@ export const useService = (): ServiceInterface => {
     // eslint-disable-next-line react-hooks/exhaustive-deps
   }, [isMounted, setIsMounted]);
 
-  useEffect(() => {
-    if (run.body?.status === 'running') {
-      const intervalId = setInterval(() => {
-        dispatch(
-          runsActions.runForId({
-            repositoryID: repositoryID,
-            runId: id,
-            onSuccess: (res) => {
-              if (res.status !== 'running') {
-                dispatch(
-                  runsActions.graphForRun({
-                    runId: id,
-                  }),
-                );
-              }
-            },
-          }),
-        );
-      }, 12000);
-
-      return () => {
-        clearInterval(intervalId);
-      };
-    }
-    // This is important
-  }, [repositoryID, id, run, dispatch]);
-
   const fetchMetaData = async () => {
     const response = await axios.get(
       `${process.env.REACT_APP_BASE_API_URL}/run-metadata?pipeline_run_id=${id}&key=orchestrator_url`,

src/ui/layouts/runs/RunDetail/useService.ts

@@ -61,31 +61,6 @@ export const useService = (): ServiceInterface => {
     }
     // eslint-disable-next-line react-hooks/exhaustive-deps
   }, [isMounted, setIsMounted]);
-  useEffect(() => {
-    if (run.body?.status === 'running') {
-      const intervalId = setInterval(() => {
-        dispatch(
-          runsActions.runForId({
-            runId: runId,
-            onSuccess: (res) => {
-              if (res.status !== 'running') {
-                dispatch(
-                  runsActions.graphForRun({
-                    runId: runId,
-                  }),
-                );
-              }
-            },
-          }),
-        );
-      }, 5000);
-
-      return () => {
-        clearInterval(intervalId);
-      };
-    }
-    // This is important
-  }, [runId, run, dispatch]);
 
   const fetchMetaData = async () => {
     const response = await axios.get(

src/ui/layouts/stacks/RunDetail/useService.ts

@@ -51,32 +51,6 @@ export const useService = (): ServiceInterface => {
     // eslint-disable-next-line react-hooks/exhaustive-deps
   }, [isMounted, setIsMounted]);
 
-  useEffect(() => {
-    if (run.body?.status === 'running') {
-      const intervalId = setInterval(() => {
-        dispatch(
-          runsActions.runForId({
-            stackId: stackId,
-            runId: id,
-            onSuccess: (res) => {
-              if (res.status !== 'running') {
-                dispatch(
-                  runsActions.graphForRun({
-                    runId: id,
-                  }),
-                );
-              }
-            },
-          }),
-        );
-      }, 5000);
-
-      return () => {
-        clearInterval(intervalId);
-      };
-    }
-    // This is important
-  }, [stackId, id, run, dispatch]);
   const fetchMetaData = async () => {
     const response = await axios.get(
       `${process.env.REACT_APP_BASE_API_URL}/run-metadata?pipeline_run_id=${id}&key=orchestrator_url`,