@@ -414,14 +414,14 @@ def clear_privileges(client)
414414 def clear_ml_jobs ( client )
415415 client . ml . close_job ( job_id : '_all' , force : true )
416416 client . ml . get_jobs [ 'jobs' ] . each do |d |
417- client . ml . delete_job ( job_id : d [ 'job_id' ] )
417+ client . ml . delete_job ( job_id : d [ 'job_id' ] , wait_for_completion : false , force : true )
418418 end
419419 end
420420
421421 def clear_datafeeds ( client )
422422 client . ml . stop_datafeed ( datafeed_id : '_all' , force : true )
423423 client . ml . get_datafeeds [ 'datafeeds' ] . each do |d |
424- client . ml . delete_datafeed ( datafeed_id : d [ 'datafeed_id' ] )
424+ client . ml . delete_datafeed ( datafeed_id : d [ 'datafeed_id' ] , force : true , timeout : '120s' )
425425 end
426426 end
427427
@@ -448,7 +448,7 @@ def clear_index_templates(client)
448448
449449 def clear_transforms ( client )
450450 client . transform . get_transform ( transform_id : '*' ) [ 'transforms' ] . each do |transform |
451- client . transform . delete_transform ( transform_id : transform [ 'id' ] )
451+ client . transform . delete_transform ( transform_id : transform [ 'id' ] , force : true )
452452 end
453453 end
454454
@@ -482,7 +482,7 @@ def delete_trained_models(client)
482482 return unless models [ 'trained_model_configs' ]
483483
484484 models [ 'trained_model_configs' ] . each do |model |
485- client . ml . delete_trained_model ( model_id : model [ 'model_id' ] , force : true , ignore : 400 )
485+ client . ml . delete_trained_model ( model_id : model [ 'model_id' ] , force : true , ignore : 400 , timeout : '120s' )
486486 end
487487 end
488488 end
0 commit comments