diff --git a/src/const.tsx b/src/const.tsx
index 9a7f2b7e..9259a903 100644
--- a/src/const.tsx
+++ b/src/const.tsx
@@ -15,6 +15,8 @@ export enum ResourceType {
 export enum PublishType {
   BUILD_DEPLOY = 'builddeploy',
   DEPLOY = 'deploy',
+  RESTART = 'restart',
+  ROLLBACK = 'rollback',
 }
 
 export enum MemberType {
diff --git a/src/pages/instances/Pods/components/ButtonBar.tsx b/src/pages/instances/Pods/components/ButtonBar.tsx
index 2779a006..3e57c56c 100644
--- a/src/pages/instances/Pods/components/ButtonBar.tsx
+++ b/src/pages/instances/Pods/components/ButtonBar.tsx
@@ -2,14 +2,16 @@ import { DownOutlined, ExclamationCircleOutlined } from '@ant-design/icons';
 import {
   Button, Dropdown, Menu, Modal, Tooltip,
 } from 'antd';
-import { history, useIntl, useModel } from 'umi';
+import {
+  history, useIntl, useModel, useRequest,
+} from 'umi';
 import { stringify } from 'query-string';
 import { useState } from 'react';
 import { RebuilddeployModal } from '@/components/rollout';
 import RBAC from '@/rbac';
 import { isRestrictedStatus } from '@/components/State';
 import { ClusterStatus, PublishType } from '@/const';
-import { deleteCluster, freeCluster, restart } from '@/services/clusters/clusters';
+import { createPipelineRun, deleteCluster, freeCluster } from '@/services/clusters/clusters';
 import { DangerText, WarningText } from '@/components/Widget';
 
 interface ButtonBarProps {
@@ -26,6 +28,13 @@ function ButtonBar(props: ButtonBarProps) {
   const { successAlert } = useModel('alert');
   const [enableRebuilddeployModal, setEnableRebuilddeployModal] = useState(false);
 
+  const { run: runRestart } = useRequest(() => createPipelineRun(id!, { action: 'restart' }), {
+    onSuccess: (pr: PIPELINES.Pipeline) => {
+      history.push(`/instances${fullPath}/-/pipelines/${pr.id}`);
+    },
+    manual: true,
+  });
+
   const onClickOperation = ({ key }: { key: string }) => {
     switch (key) {
       case 'builddeploy':
@@ -43,9 +52,7 @@ function ButtonBar(props: ButtonBarProps) {
         Modal.confirm({
           title: intl.formatMessage({ id: 'pages.message.cluster.restart.confirm' }),
           onOk() {
-            restart(id).then(() => {
-              successAlert(intl.formatMessage({ id: 'pages.message.cluster.restart.success' }));
-            });
+            runRestart();
           },
         });
         break;
diff --git a/src/pages/instances/Pods/components/ButtonBarV2.tsx b/src/pages/instances/Pods/components/ButtonBarV2.tsx
index 4ff46796..501aa5aa 100644
--- a/src/pages/instances/Pods/components/ButtonBarV2.tsx
+++ b/src/pages/instances/Pods/components/ButtonBarV2.tsx
@@ -2,14 +2,16 @@ import { DownOutlined, ExclamationCircleOutlined } from '@ant-design/icons';
 import {
   Button, Dropdown, Menu, Modal, Tooltip,
 } from 'antd';
-import { history, useIntl, useModel } from 'umi';
+import {
+  history, useIntl, useModel, useRequest,
+} from 'umi';
 import { stringify } from 'query-string';
 import { useState } from 'react';
 import { RebuilddeployModal } from '@/components/rollout';
 import RBAC from '@/rbac';
 import { isRestrictedStatus } from '@/components/State';
 import { ClusterStatus, PublishType } from '@/const';
-import { deleteCluster, freeCluster, restart } from '@/services/clusters/clusters';
+import { createPipelineRun, deleteCluster, freeCluster } from '@/services/clusters/clusters';
 import { CatalogType } from '@/services/core';
 import { DangerText, WarningText } from '@/components/Widget';
 
@@ -30,6 +32,13 @@ function ButtonBarV2(props: ButtonBarProps) {
   const { successAlert } = useModel('alert');
   const [enableRebuilddeployModal, setEnableRebuilddeployModal] = useState(false);
 
+  const { run: runRestart } = useRequest(() => createPipelineRun(id!, { action: 'restart' }), {
+    onSuccess: (pr: PIPELINES.Pipeline) => {
+      history.push(`/instances${fullPath}/-/pipelines/${pr.id}`);
+    },
+    manual: true,
+  });
+
   const onClickOperation = ({ key }: { key: string }) => {
     switch (key) {
       case 'builddeploy':
@@ -47,9 +56,7 @@ function ButtonBarV2(props: ButtonBarProps) {
         Modal.confirm({
           title: intl.formatMessage({ id: 'pages.message.cluster.restart.confirm' }),
           onOk() {
-            restart(id).then(() => {
-              successAlert(intl.formatMessage({ id: 'pages.message.cluster.restart.success' }));
-            });
+            runRestart();
           },
         });
         break;
diff --git a/src/pages/instances/pipelines/Detail/MergeBox.tsx b/src/pages/instances/pipelines/Detail/MergeBox.tsx
index 999667af..74fc3543 100644
--- a/src/pages/instances/pipelines/Detail/MergeBox.tsx
+++ b/src/pages/instances/pipelines/Detail/MergeBox.tsx
@@ -86,13 +86,17 @@ const Status = (props: StatusProps) => {
 
 interface ConfirmButtonProps extends Omit<ButtonProps, 'type'> {
   pipelinerunID: number;
+  pipelinerunAction: string;
   forceRun: boolean;
 }
 
 const ConfirmButton = (props: ConfirmButtonProps) => {
-  const { pipelinerunID, forceRun: forceRunFlag, disabled } = props;
+  const {
+    pipelinerunID, pipelinerunAction, forceRun: forceRunFlag, disabled,
+  } = props;
   const intl = useIntl();
   const history = useHistory();
+  const { successAlert } = useModel('alert');
   const { initialState } = useModel('@@initialState');
   const { fullPath } = initialState?.resource || {};
 
@@ -109,32 +113,35 @@ const ConfirmButton = (props: ConfirmButtonProps) => {
     };
   }, [forceRunFlag, intl, disabled]);
 
-  const { run } = useRequest(() => runPipelineRun(pipelinerunID), {
-    onSuccess: () => {
-      history.push(`${fullPath}`);
-    },
-    manual: true,
-  });
+  const doRun = useCallback(() => {
+    if (forceRunFlag) {
+      return forceRunPipelineRun(pipelinerunID);
+    }
+    return runPipelineRun(pipelinerunID);
+  }, [forceRunFlag, pipelinerunID]);
 
-  const { run: forceRun } = useRequest(() => forceRunPipelineRun(pipelinerunID), {
+  const { run, loading } = useRequest(() => doRun(), {
     onSuccess: () => {
+      switch (pipelinerunAction) {
+        case 'restart':
+          successAlert(intl.formatMessage({ id: 'pages.message.cluster.restart.success' }));
+          break;
+        case 'rollback':
+          successAlert(intl.formatMessage({ id: 'pages.message.cluster.rollback.submitted' }));
+          break;
+        default:
+          break;
+      }
       history.push(`${fullPath}`);
     },
     manual: true,
   });
 
-  const onClick = useCallback(() => {
-    if (forceRunFlag) {
-      forceRun();
-    } else {
-      run();
-    }
-  }, [forceRunFlag, forceRun, run]);
-
   return (
     <Button
       type="primary"
-      onClick={onClick}
+      loading={loading}
+      onClick={run}
       style={{ backgroundColor: params.color, borderColor: params.color }}
       {...props}
     >
@@ -233,7 +240,7 @@ const CheckRunItem = (props: { checkrun: PIPELINES.CheckRun }) => {
 };
 
 const MergeBox = (props: { pipelinerun: PIPELINES.Pipeline, checkruns?: PIPELINES.CheckRun[] }) => {
-  const { pipelinerun: { status, id }, checkruns = [] } = props;
+  const { pipelinerun: { status, id, action }, checkruns = [] } = props;
   const needButton = useMemo(() => status === 'ready' || status === 'pending', [status]);
   return (
     <Row>
@@ -249,6 +256,7 @@ const MergeBox = (props: { pipelinerun: PIPELINES.Pipeline, checkruns?: PIPELINE
                   <ConfirmButton
                     forceRun={status === 'pending' && rbac.Permissions.forceRunPipelineRun.allowed}
                     pipelinerunID={id}
+                    pipelinerunAction={action}
                     disabled={status === 'pending' && !rbac.Permissions.forceRunPipelineRun.allowed}
                   />
                   <CancelButton pipelinerunID={id} />
diff --git a/src/pages/instances/pipelines/Detail/index.tsx b/src/pages/instances/pipelines/Detail/index.tsx
index 77b2d101..92424155 100644
--- a/src/pages/instances/pipelines/Detail/index.tsx
+++ b/src/pages/instances/pipelines/Detail/index.tsx
@@ -6,9 +6,7 @@ import { useParams } from 'umi';
 import { useRequest } from '@@/plugin-request/request';
 import copy from 'copy-to-clipboard';
 import { useMemo, useState } from 'react';
-import {
-  Button, Card, Modal,
-} from 'antd';
+import { Button, Card, Modal } from 'antd';
 import { CopyOutlined, FullscreenOutlined, ExclamationCircleOutlined } from '@ant-design/icons';
 import PageWithBreadcrumb from '@/components/PageWithBreadcrumb';
 import type { Param } from '@/components/DetailCard';
@@ -29,7 +27,7 @@ import {
 import Utils from '@/utils';
 import { PublishType } from '@/const';
 import FullscreenModal from '@/components/FullscreenModal';
-import { rollback } from '@/services/clusters/clusters';
+import { createPipelineRun } from '@/services/clusters/clusters';
 import { GitRefType } from '@/services/code/code';
 import ButtonWithoutPadding from '@/components/Widget/ButtonWithoutPadding';
 import MergeBox from './MergeBox';
@@ -49,15 +47,21 @@ export default (props: any) => {
   const { initialState } = useModel('@@initialState');
   const { id, fullPath } = initialState!.resource;
 
-  const pollingInterval = 6000;
+  const pollingInterval = 3000;
 
-  const { data: pipeline } = useRequest(() => getPipeline(pipelineID), {
+  const { data: checkruns, cancel: cancelListCheckRuns } = useRequest(() => listCheckRuns(pipelineID), {
     pollingInterval,
     pollingWhenHidden: false,
   });
-  const { data: checkruns } = useRequest(() => listCheckRuns(pipelineID), {
+  const { data: pipeline, cancel: cancelGetPipeline } = useRequest(() => getPipeline(pipelineID), {
     pollingInterval,
     pollingWhenHidden: false,
+    onSuccess: (data) => {
+      if (data?.status && data?.status !== 'pending') {
+        cancelListCheckRuns();
+        cancelGetPipeline();
+      }
+    },
   });
   const { data: diff } = useRequest(() => getPipelineDiffs(pipelineID));
   const { data: buildLog } = useRequest(() => queryPipelineLog(pipelineID), {
@@ -160,11 +164,13 @@ export default (props: any) => {
     setFullscreen(true);
   };
 
-  const { run: runRollback, loading } = useRequest((prID: number) => rollback(id, { pipelinerunID: prID }), {
-    onSuccess: () => {
-      // jump to pods' url
-      successAlert(intl.formatMessage({ id: 'pages.message.cluster.rollback.submitted' }));
-      history.push(`${fullPath}`);
+  const { run: runRollback, loading } = useRequest((prID: number) => createPipelineRun(id, {
+    action: 'rollback',
+    pipelinerunID: prID,
+  }), {
+    onSuccess: (pr: PIPELINES.Pipeline) => {
+      history.push(`/instances${fullPath}/-/pipelines/${pr.id}`);
+      window.location.reload();
     },
     manual: true,
   });
diff --git a/src/services/clusters.d.ts b/src/services/clusters.d.ts
index c7ba4d1d..78913b45 100644
--- a/src/services/clusters.d.ts
+++ b/src/services/clusters.d.ts
@@ -179,8 +179,8 @@ declare namespace CLUSTER {
   };
 
   type PipelineRunCreate = {
-    action: 'builddeploy' | 'deploy' | 'rollback'
-    title: string,
+    action: 'builddeploy' | 'deploy' | 'rollback' | 'restart'
+    title?: string,
     description?: string;
     git?: {
       branch: string;