Skip to content

Commit 84df572

Browse files
committed
Improve logging
1 parent 1a42ae6 commit 84df572

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

cid/common.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -458,9 +458,14 @@ def create_datasets(self, _datasets: list) -> dict:
458458
if ds.get('Name') == dataset_name:
459459
missing_datasets.remove(dataset_name)
460460
print(f"\n\tFound {dataset_name} as {raw_template.get('DataSetId')}")
461+
except FileNotFoundError:
462+
logger.info(f'File "{dataset_file}" not found')
463+
pass
461464
except self.qs.client.exceptions.ResourceNotFoundException:
465+
logger.info(f'Dataset "{dataset_name}" not found')
462466
pass
463467
except self.qs.client.exceptions.AccessDeniedException:
468+
logger.info(f'Access denied trying to find dataset "{dataset_name}"')
464469
pass
465470
except:
466471
raise
@@ -550,7 +555,7 @@ def create_dataset(self, dataset_definition) -> bool:
550555
logger.info('No Athena datasources found, attempting to create one')
551556
self.qs.create_data_source()
552557
if not len(self.qs.athena_datasources):
553-
logger.error('No Athena datasources available, failing')
558+
logger.info('No Athena datasources available, failing')
554559
return False
555560
# Load TPL file
556561
columns_tpl = dict()

cid/helpers/athena.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ def execute_query(self, sql_query, sleep_duration=1) -> str:
174174
else:
175175
failure_reason = response['QueryExecution']['Status']['StateChangeReason']
176176
logger.error('Athena query failed: {}'.format(failure_reason))
177-
logger.error('Full query: {}'.format(sql_query))
177+
logger.info('Full query: {}'.format(sql_query))
178178

179179
raise Exception(failure_reason)
180180

0 commit comments

Comments
 (0)