@@ -43,17 +43,13 @@ function assetsWithValidUids () {
4343async function waitForJobReady ( jobId , maxAttempts = 15 ) {
4444 for ( let attempt = 1 ; attempt <= maxAttempts ; attempt ++ ) {
4545 try {
46- const response = await doBulkOperationWithManagementToken ( tokenUidDev )
46+ const response = await doBulkOperation ( )
4747 . jobStatus ( { job_id : jobId , api_version : '3.2' } )
48-
4948 if ( response && response . status ) {
5049 return response
5150 }
52- if ( attempt === 1 ) {
53- console . log ( ` jobStatus for ${ jobId } returned undefined on first attempt, will keep polling...` )
54- }
5551 } catch ( error ) {
56- console . log ( `Attempt ${ attempt } / ${ maxAttempts } : Job ${ jobId } not ready — ${ error . message || 'retrying...' } ` )
52+ // retry
5753 }
5854 await delay ( 5000 )
5955 }
@@ -364,6 +360,8 @@ describe('BulkOperation api test', () => {
364360 } )
365361
366362 it ( 'should wait for jobs to be ready and get job status for the first publish job' , async function ( ) {
363+ this . timeout ( 90000 )
364+
367365 const response = await waitForJobReady ( jobId1 )
368366 expect ( response ) . to . not . equal ( undefined )
369367 expect ( response . uid ) . to . not . equal ( undefined )
@@ -386,6 +384,8 @@ describe('BulkOperation api test', () => {
386384 } )
387385
388386 it ( 'should get job status for the second publish job' , async function ( ) {
387+ this . timeout ( 90000 )
388+
389389 const response = await waitForJobReady ( jobId2 )
390390 expect ( response ) . to . not . equal ( undefined )
391391 expect ( response . uid ) . to . not . equal ( undefined )
@@ -396,6 +396,8 @@ describe('BulkOperation api test', () => {
396396 } )
397397
398398 it ( 'should get job status for the third publish job' , async function ( ) {
399+ this . timeout ( 90000 )
400+
399401 const response = await waitForJobReady ( jobId3 )
400402 expect ( response ) . to . not . equal ( undefined )
401403 expect ( response . uid ) . to . not . equal ( undefined )
@@ -406,6 +408,8 @@ describe('BulkOperation api test', () => {
406408 } )
407409
408410 it ( 'should get job status for publishAllLocalized=true job' , async function ( ) {
411+ this . timeout ( 90000 )
412+
409413 const response = await waitForJobReady ( jobId4 )
410414 expect ( response ) . to . not . equal ( undefined )
411415 expect ( response . uid ) . to . not . equal ( undefined )
@@ -416,6 +420,8 @@ describe('BulkOperation api test', () => {
416420 } )
417421
418422 it ( 'should get job status for publishAllLocalized=false job' , async function ( ) {
423+ this . timeout ( 90000 )
424+
419425 const response = await waitForJobReady ( jobId5 )
420426 expect ( response ) . to . not . equal ( undefined )
421427 expect ( response . uid ) . to . not . equal ( undefined )
@@ -426,6 +432,8 @@ describe('BulkOperation api test', () => {
426432 } )
427433
428434 it ( 'should get job status for asset publishAllLocalized job' , async function ( ) {
435+ this . timeout ( 90000 )
436+
429437 const response = await waitForJobReady ( jobId6 )
430438 expect ( response ) . to . not . equal ( undefined )
431439 expect ( response . uid ) . to . not . equal ( undefined )
@@ -436,6 +444,8 @@ describe('BulkOperation api test', () => {
436444 } )
437445
438446 it ( 'should get job status for unpublishAllLocalized=true job' , async function ( ) {
447+ this . timeout ( 90000 )
448+
439449 const response = await waitForJobReady ( jobId7 )
440450 expect ( response ) . to . not . equal ( undefined )
441451 expect ( response . uid ) . to . not . equal ( undefined )
@@ -446,6 +456,8 @@ describe('BulkOperation api test', () => {
446456 } )
447457
448458 it ( 'should get job status for unpublishAllLocalized=false job' , async function ( ) {
459+ this . timeout ( 90000 )
460+
449461 const response = await waitForJobReady ( jobId8 )
450462 expect ( response ) . to . not . equal ( undefined )
451463 expect ( response . uid ) . to . not . equal ( undefined )
@@ -456,6 +468,8 @@ describe('BulkOperation api test', () => {
456468 } )
457469
458470 it ( 'should get job status for asset unpublishAllLocalized job' , async function ( ) {
471+ this . timeout ( 90000 )
472+
459473 const response = await waitForJobReady ( jobId9 )
460474 expect ( response ) . to . not . equal ( undefined )
461475 expect ( response . uid ) . to . not . equal ( undefined )
@@ -466,6 +480,8 @@ describe('BulkOperation api test', () => {
466480 } )
467481
468482 it ( 'should get job status for multiple parameters job' , async function ( ) {
483+ this . timeout ( 90000 )
484+
469485 const response = await waitForJobReady ( jobId10 )
470486 expect ( response ) . to . not . equal ( undefined )
471487 expect ( response . uid ) . to . not . equal ( undefined )
@@ -476,6 +492,8 @@ describe('BulkOperation api test', () => {
476492 } )
477493
478494 it ( 'should get job status with bulk_version parameter' , async function ( ) {
495+ this . timeout ( 90000 )
496+
479497 await waitForJobReady ( jobId1 )
480498 const response = await doBulkOperationWithManagementToken ( tokenUidDev )
481499 . jobStatus ( { job_id : jobId1 , bulk_version : 'v3' , api_version : '3.2' } )
@@ -488,6 +506,8 @@ describe('BulkOperation api test', () => {
488506 } )
489507
490508 it ( 'should get job items for a completed job' , async function ( ) {
509+ this . timeout ( 90000 )
510+
491511 await waitForJobReady ( jobId1 )
492512 const response = await doBulkOperationWithManagementToken ( tokenUidDev )
493513 . getJobItems ( jobId1 )
@@ -496,6 +516,8 @@ describe('BulkOperation api test', () => {
496516 } )
497517
498518 it ( 'should get job items with explicit api_version' , async function ( ) {
519+ this . timeout ( 90000 )
520+
499521 await waitForJobReady ( jobId2 )
500522 const response = await doBulkOperationWithManagementToken ( tokenUidDev )
501523 . getJobItems ( jobId2 , { api_version : '3.2' } )
0 commit comments