File tree Expand file tree Collapse file tree 1 file changed +16
-1
lines changed Expand file tree Collapse file tree 1 file changed +16
-1
lines changed Original file line number Diff line number Diff line change @@ -173,14 +173,29 @@ var testUtils = function testUtils() {
173173
174174 this . triggerJobToRun = function ( jobName , callback ) {
175175 var request = reqq . agent ( this . url ) ;
176+ var self = this ;
176177 request . get ( "/jobs/i?jobName=" + encodeURIComponent ( jobName ) + "&action=runNow&api_key=" + props . API_KEY_ADMIN )
177178 . expect ( 200 )
178- . end ( function ( err , res ) {
179+ . end ( async function ( err , res ) {
179180 console . log ( res . text ) ;
180181 if ( err ) {
181182 callback ( err ) ;
182183 }
183184 else {
185+ var retries = 10 ;
186+ for ( var i = 0 ; i < retries ; i ++ ) {
187+ //do query to check if deletions are done
188+ var del = await self . db . collection ( "deletion_manager" ) . findOne ( { } ) ;
189+ if ( ! del ) {
190+ i = retries ;
191+ }
192+ else {
193+ console . log ( "Waiting for deletions to finish..." ) ;
194+ await new Promise ( r => setTimeout ( r , 5000 ) ) ;
195+
196+ }
197+ }
198+ //
184199 callback ( ) ;
185200 }
186201 } ) ;
You can’t perform that action at this time.
0 commit comments