1
1
import { useRef } from 'react'
2
2
3
- import { DEFAULT_ENV , getEnvironmentListMinPublic , useQuery , useQueryClient } from '@devtron-labs/devtron-fe-common-lib'
3
+ import { DEFAULT_ENV , getEnvironmentListMinPublic , useQuery } from '@devtron-labs/devtron-fe-common-lib'
4
4
5
5
import { getWorkflowStatus } from '@Components/app/service'
6
6
import { processWorkflowStatuses } from '@Components/ApplicationGroup/AppGroup.utils'
@@ -14,7 +14,6 @@ const DEFAULT_POLLING_INTERVAL = 30000
14
14
const PROGRESSING_POLLING_INTERVAL = 10000
15
15
16
16
export const useTriggerViewServices = ( { appId, isJobView, filteredEnvIds } : UseTriggerViewServicesParams ) => {
17
- const queryClient = useQueryClient ( )
18
17
const refetchIntervalRef = useRef < number > ( DEFAULT_POLLING_INTERVAL )
19
18
20
19
const { data : hostUrlConfig } = useQuery ( {
@@ -57,6 +56,7 @@ export const useTriggerViewServices = ({ appId, isJobView, filteredEnvIds }: Use
57
56
isFetching : isWorkflowsLoading ,
58
57
data : wfData ,
59
58
error : workflowsError ,
59
+ refetch : refetchWorkflows ,
60
60
} = useQuery ( {
61
61
queryKey : [ appId , isJobView , filteredEnvIds , 'triggerViewWorkflowList' ] ,
62
62
queryFn : async ( ) => {
@@ -76,7 +76,7 @@ export const useTriggerViewServices = ({ appId, isJobView, filteredEnvIds }: Use
76
76
77
77
const { workflows, filteredCIPipelines } = wfData ?? { workflows : [ ] , filteredCIPipelines : [ ] }
78
78
79
- const { data : updatedWfWithStatus } = useQuery ( {
79
+ const { data : updatedWfWithStatus , refetch : reloadWorkflowStatus } = useQuery ( {
80
80
queryKey : [ appId , 'triggerViewWorkflowStatus' ] ,
81
81
queryFn : ( { signal } ) => getWorkflowStatus ( + appId , { signal } ) ,
82
82
select : ( response ) => {
@@ -97,13 +97,8 @@ export const useTriggerViewServices = ({ appId, isJobView, filteredEnvIds }: Use
97
97
98
98
const isLoading = isEnvListLoading || isWorkflowsLoading
99
99
100
- const reloadWorkflowStatus = async ( ) => {
101
- await queryClient . invalidateQueries ( { queryKey : [ appId , 'triggerViewWorkflowStatus' ] } )
102
- }
103
-
104
100
const reloadWorkflows = async ( ) => {
105
- await queryClient . invalidateQueries ( { queryKey : [ appId , isJobView , filteredEnvIds , 'triggerViewWorkflowList' ] } )
106
- // Invalidate status query to refetch workflow status
101
+ await refetchWorkflows ( )
107
102
await reloadWorkflowStatus ( )
108
103
}
109
104
0 commit comments