@@ -49,6 +49,9 @@ const {
4949 DD_CAPABILITIES_TEST_IMPACT_ANALYSIS ,
5050 DD_CAPABILITIES_EARLY_FLAKE_DETECTION ,
5151 DD_CAPABILITIES_AUTO_TEST_RETRIES ,
52+ DD_CAPABILITIES_TEST_MANAGEMENT_QUARANTINE ,
53+ DD_CAPABILITIES_TEST_MANAGEMENT_DISABLE ,
54+ DD_CAPABILITIES_TEST_MANAGEMENT_ATTEMPT_TO_FIX ,
5255 TEST_MANAGEMENT_IS_ATTEMPT_TO_FIX ,
5356 TEST_HAS_FAILED_ALL_RETRIES ,
5457 TEST_MANAGEMENT_ATTEMPT_TO_FIX_PASSED
@@ -3041,44 +3044,55 @@ describe('mocha CommonJS', function () {
30413044 } )
30423045
30433046 context ( 'libraries capabilities' , ( ) => {
3044- it ( 'adds capabilities to tests' , ( done ) => {
3045- receiver . setSettings ( {
3046- flaky_test_retries_enabled : true ,
3047- itr_enabled : true ,
3048- early_flake_detection : {
3049- enabled : true
3050- } ,
3051- known_tests_enabled : true
3052- } )
3053-
3054- const eventsPromise = receiver . gatherPayloadsMaxTimeout ( ( { url } ) => url . endsWith ( 'citestcycle' ) , ( payloads ) => {
3047+ const getTestAssertions = ( isParallel ) =>
3048+ receiver . gatherPayloadsMaxTimeout ( ( { url } ) => url . endsWith ( 'citestcycle' ) , ( payloads ) => {
30553049 const metadataDicts = payloads . flatMap ( ( { payload } ) => payload . metadata )
30563050
30573051 assert . isNotEmpty ( metadataDicts )
30583052 metadataDicts . forEach ( metadata => {
3059- assert . equal ( metadata . test [ DD_CAPABILITIES_TEST_IMPACT_ANALYSIS ] , 'true' )
3060- assert . equal ( metadata . test [ DD_CAPABILITIES_EARLY_FLAKE_DETECTION ] , 'true' )
3061- assert . equal ( metadata . test [ DD_CAPABILITIES_AUTO_TEST_RETRIES ] , 'true' )
3053+ if ( isParallel ) {
3054+ assert . equal ( metadata . test [ DD_CAPABILITIES_TEST_IMPACT_ANALYSIS ] , undefined )
3055+ assert . equal ( metadata . test [ DD_CAPABILITIES_TEST_MANAGEMENT_ATTEMPT_TO_FIX ] , undefined )
3056+ } else {
3057+ assert . equal ( metadata . test [ DD_CAPABILITIES_TEST_IMPACT_ANALYSIS ] , '1' )
3058+ assert . equal ( metadata . test [ DD_CAPABILITIES_TEST_MANAGEMENT_ATTEMPT_TO_FIX ] , '2' )
3059+ }
3060+ assert . equal ( metadata . test [ DD_CAPABILITIES_EARLY_FLAKE_DETECTION ] , '1' )
3061+ assert . equal ( metadata . test [ DD_CAPABILITIES_AUTO_TEST_RETRIES ] , '1' )
3062+ assert . equal ( metadata . test [ DD_CAPABILITIES_TEST_MANAGEMENT_QUARANTINE ] , '1' )
3063+ assert . equal ( metadata . test [ DD_CAPABILITIES_TEST_MANAGEMENT_DISABLE ] , '1' )
30623064 // capabilities logic does not overwrite test session name
30633065 assert . equal ( metadata . test [ TEST_SESSION_NAME ] , 'my-test-session-name' )
30643066 } )
30653067 } )
30663068
3069+ const runTest = ( done , isParallel , extraEnvVars = { } ) => {
3070+ const testAssertionsPromise = getTestAssertions ( isParallel )
3071+
30673072 childProcess = exec (
30683073 runTestsWithCoverageCommand ,
30693074 {
30703075 cwd,
30713076 env : {
30723077 ...getCiVisAgentlessConfig ( receiver . port ) ,
3073- DD_TEST_SESSION_NAME : 'my-test-session-name'
3078+ DD_TEST_SESSION_NAME : 'my-test-session-name' ,
3079+ ...extraEnvVars
30743080 } ,
30753081 stdio : 'inherit'
30763082 }
30773083 )
30783084 childProcess . on ( 'exit' , ( ) => {
3079- eventsPromise . then ( ( ) => {
3080- done ( )
3081- } ) . catch ( done )
3085+ testAssertionsPromise . then ( ( ) => done ( ) ) . catch ( done )
3086+ } )
3087+ }
3088+
3089+ it ( 'adds capabilities to tests' , ( done ) => {
3090+ runTest ( done , false )
3091+ } )
3092+
3093+ it ( 'adds capabilities to tests (parallel)' , ( done ) => {
3094+ runTest ( done , true , {
3095+ RUN_IN_PARALLEL : '1'
30823096 } )
30833097 } )
30843098 } )
0 commit comments