File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -70,7 +70,11 @@ import type {
7070 WorkflowGroupDependencies ,
7171 WorkflowGroupOutput ,
7272} from '@/lib/table'
73- import { areOutputsFilled , optimisticallyScheduleNewlyEligibleGroups } from '@/lib/table/deps'
73+ import {
74+ areOutputsFilled ,
75+ hasRunningGroupExecution ,
76+ optimisticallyScheduleNewlyEligibleGroups ,
77+ } from '@/lib/table/deps'
7478
7579const logger = createLogger ( 'TableQueries' )
7680
Original file line number Diff line number Diff line change @@ -24,6 +24,15 @@ export function isExecInFlight(exec: RowExecutionMetadata | undefined): boolean
2424 return false
2525}
2626
27+ export function hasRunningGroupExecution ( rows : TableRow [ ] ) : boolean {
28+ for ( const row of rows ) {
29+ for ( const exec of Object . values ( row . executions ) ) {
30+ if ( isExecInFlight ( exec ) ) return true
31+ }
32+ }
33+ return false
34+ }
35+
2736/**
2837 * True when every output column the group writes still has a non-empty value
2938 * on this row. The "completed" exec status is metadata, but the cells are the
You can’t perform that action at this time.
0 commit comments