28
28
# Setup logging
29
29
LOGGER = logging .getLogger ("docker-splunk" )
30
30
LOGGER .setLevel (logging .INFO )
31
- file_handler = logging .handlers .RotatingFileHandler ("/builds/core-ee/docker-images /docker_splunk_tests.log" , maxBytes = 25000000 )
31
+ file_handler = logging .handlers .RotatingFileHandler (". /docker_splunk_tests.log" , maxBytes = 25000000 )
32
32
formatter = logging .Formatter ('%(asctime)s %(levelname)s [%(name)s] [%(process)d] %(message)s' )
33
33
file_handler .setFormatter (formatter )
34
34
LOGGER .addHandler (file_handler )
@@ -128,7 +128,6 @@ def wait_for_containers(self, count, label=None, name=None, timeout=500):
128
128
'''
129
129
NOTE: This helper method can only be used for `compose up` scenarios where self.project_name is defined
130
130
'''
131
- print (f"now WAITING for CONTAINERS to be UP" )
132
131
start = time .time ()
133
132
end = start
134
133
# Wait
@@ -153,22 +152,14 @@ def wait_for_containers(self, count, label=None, name=None, timeout=500):
153
152
print (f"SCRIPT FAILS TO CREATE CONTAINER" )
154
153
sys .exit (1 )
155
154
elif "Ansible playbook complete" in output :
156
- print (f"ANSIBLE EXEC COMPLETE" )
157
155
self .logger .info ("Container {} is ready" .format (container ["Names" ][0 ]))
158
156
healthy_count += 1
159
- else :
160
- print (f"IN ELSE WHICH WAS NOT EXPECTED:" )
161
- print ("-------- START LOG ----------" )
162
- print (output )
163
- print ("-------- END LOG ----------" )
164
157
else :
165
- print ("ALL GOOD ELSE" )
166
158
self .logger .info ("Container {} is ready" .format (container ["Names" ][0 ]))
167
159
healthy_count += 1
168
160
if healthy_count == count :
169
161
self .logger .info ("All containers ready to proceed" )
170
162
break
171
- print (f"continue for loop without break" )
172
163
time .sleep (5 )
173
164
end = time .time ()
174
165
return True
@@ -234,19 +225,19 @@ def _run_splunk_query(self, container_id, query, username="admin", password="pas
234
225
def compose_up (self , defaults_url = None , apps_url = None ):
235
226
container_count = self .get_number_of_containers (os .path .join (self .SCENARIOS_DIR , self .compose_file_name ))
236
227
command = "docker compose -p {} -f test_scenarios/{} up -d" .format (self .project_name , self .compose_file_name )
237
- print (f"LOOK AT THIS COMMAND" )
238
- print (command )
239
228
out , err , rc = self ._run_command (command , defaults_url , apps_url )
240
- print ("COMPLETED DOCKER COMPOSE" )
241
- print (f"check RC for docker compose: { rc } ; check err for docker compose: { err } " )
242
- print ("check output for docker compose" )
243
- print (out )
244
229
return container_count , rc
245
230
246
231
def extract_json (self , container_name ):
247
232
retries = 15
248
233
for i in range (retries ):
234
+ print ("DEBUG: EXTRACT JSON" )
235
+ import time
236
+ print ("sleeping now for 10; check if docker container exists" )
237
+ self .logger .info ("sleeping now for 10; check if docker container exists" )
238
+ time .sleep (20 )
249
239
exec_command = self .client .exec_create (container_name , "cat /opt/container_artifact/ansible_inventory.json" )
240
+ print (f"collect exec command: { exec_command } " )
250
241
json_data = self .client .exec_start (exec_command )
251
242
if "No such file or directory" in json_data :
252
243
time .sleep (5 )
0 commit comments