@@ -74,6 +74,7 @@ def wipe_cluster(client)
74
74
clear_datafeeds ( client )
75
75
delete_data_frame_analytics ( client )
76
76
delete_filters ( client )
77
+ clear_transforms ( client )
77
78
end
78
79
delete_all_ilm_policies ( client ) if @has_ilm
79
80
delete_all_follow_patterns ( client ) if @has_ccr
@@ -364,7 +365,7 @@ def clear_index_templates(client)
364
365
365
366
def clear_transforms ( client )
366
367
client . transform . get_transform ( transform_id : '*' ) [ 'transforms' ] . each do |transform |
367
- client . transform . delete_transform ( transform_id : transform [ :id ] )
368
+ client . transform . delete_transform ( transform_id : transform [ 'id' ] )
368
369
end
369
370
end
370
371
@@ -377,7 +378,7 @@ def clear_ml_filters(client)
377
378
378
379
def delete_all_node_shutdown_metadata ( client )
379
380
nodes = client . shutdown . get_node
380
- return unless nodes
381
+ return unless nodes [ 'nodes' ]
381
382
382
383
nodes [ 'nodes' ] . each do |node |
383
384
client . shutdown . delete_node ( node [ 'node_id' ] )
@@ -393,6 +394,7 @@ def wipe_calendars(client)
393
394
394
395
def delete_data_frame_analytics ( client )
395
396
dfs = client . ml . get_data_frame_analytics
397
+ return unless dfs [ 'data_frame_analytics' ]
396
398
397
399
dfs [ 'data_frame_analytics' ] . each do |df |
398
400
client . ml . delete_data_frame_analytics ( id : df [ 'id' ] , force : true )
0 commit comments