in lambdas/helper/dal.py [0:0]
def find_package(self, package_name, package_version):
DataAccessLayer._xray_start('find_package')
try:
sql_parameters = [
{'name':'package_name', 'value':{'stringValue': package_name}},
{'name':'package_version', 'value':{'stringValue': package_version}},
]
sql = f'select package_name, package_version' \
f' from {package_table_name}' \
f' where package_name=:package_name' \
f' and package_version=:package_version'
response = self.execute_statement(sql, sql_parameters)
results = [
{
'package_name': record[0]['stringValue'],
'package_version': record[1]['stringValue']
}
for record in response['records']
]
return results
except DataAccessLayerException as de:
raise de
except Exception as e:
raise DataAccessLayerException(e) from e
finally:
DataAccessLayer._xray_stop()