11import { randomUUID } from 'crypto' ;
22import { ExecutionContext } from 'ava' ;
33import { firstValueFrom , Subject } from 'rxjs' ;
4+ import asyncRetry from 'async-retry' ;
45import { CountWorkflowExecution , WorkflowFailedError } from '@temporalio/client' ;
56import * as activity from '@temporalio/activity' ;
67import { msToNumber , tsToMs } from '@temporalio/common/lib/time' ;
@@ -16,7 +17,6 @@ import * as workflows from './workflows';
1617import { Context , helpers , makeTestFunction } from './helpers-integration' ;
1718import { overrideSdkInternalFlag } from './mock-internal-flags' ;
1819import { asSdkLoggerSink , loadHistory , RUN_TIME_SKIPPING_TESTS , waitUntil } from './helpers' ;
19- import asyncRetry from 'async-retry' ;
2020
2121const test = makeTestFunction ( {
2222 workflowsPath : __filename ,
@@ -1287,11 +1287,11 @@ test('Count workflow executions', async (t) => {
12871287 await Promise . all ( [
12881288 executeWorkflow ( completableWorkflow , { args : [ true ] } ) ,
12891289 executeWorkflow ( completableWorkflow , { args : [ true ] } ) ,
1290- executeWorkflow ( completableWorkflow , { args : [ true ] } )
1291- ] )
1290+ executeWorkflow ( completableWorkflow , { args : [ true ] } ) ,
1291+ ] ) ;
12921292 } catch ( err ) {
1293- throw new Error ( 'executing workflow unexpectedly failed' )
1294- } ;
1293+ throw new Error ( 'executing workflow unexpectedly failed' ) ;
1294+ }
12951295 } ) ;
12961296
12971297 const actualTotal = await client . workflow . count ( `TaskQueue = '${ taskQueue } '` ) ;
@@ -1304,7 +1304,7 @@ test('Count workflow executions', async (t) => {
13041304 { count : 3 , groupValues : [ [ 'Completed' ] ] } ,
13051305 ] ,
13061306 } ;
1307-
1307+
13081308 const actualByExecutionStatus = await client . workflow . count ( `TaskQueue = '${ taskQueue } ' GROUP BY ExecutionStatus` ) ;
13091309 t . deepEqual ( actualByExecutionStatus , expectedByExecutionStatus ) ;
13101310} ) ;
0 commit comments