diff --git a/contents/job-wait.py b/contents/job-wait.py index bec2b09..4d62a70 100644 --- a/contents/job-wait.py +++ b/contents/job-wait.py @@ -83,7 +83,10 @@ def wait(): for line in w.stream(core_v1.read_namespaced_pod_log, name=pod_name, namespace=namespace): - log.info(line.encode('ascii', 'ignore')) + try: + log.info(line) + except: + log.info(line.encode('ascii', 'ignore')) #check status job batch_v1 = client.BatchV1Api() diff --git a/contents/pods-read-logs.py b/contents/pods-read-logs.py index 4946d60..622fca3 100644 --- a/contents/pods-read-logs.py +++ b/contents/pods-read-logs.py @@ -35,7 +35,10 @@ def main(): name=data["name"], tail_lines=os.environ.get('RD_CONFIG_NUMBER_OF_LINES'), follow=False): - print(line.encode('ascii', 'ignore')) + try: + log.info(line) + except: + log.info(line.encode('ascii', 'ignore')) else: w = watch.Watch() for line in w.stream(v1.read_namespaced_pod_log, @@ -44,7 +47,10 @@ def main(): name=data["name"], tail_lines=os.environ.get('RD_CONFIG_NUMBER_OF_LINES'), follow=False): - print(line.encode('ascii', 'ignore')) + try: + log.info(line) + except: + log.info(line.encode('ascii', 'ignore')) else: if data["container_name"]: ret = v1.read_namespaced_pod_log(