Skip to content
Snippets Groups Projects
Commit dffb127c authored by Antoine Pietri's avatar Antoine Pietri
Browse files

athena: pass database name as an attribute

parent 01ba5d14
No related branches found
No related tags found
No related merge requests found
...@@ -107,6 +107,7 @@ def create_tables(database_name, dataset_location, output_location=None, replace ...@@ -107,6 +107,7 @@ def create_tables(database_name, dataset_location, output_location=None, replace
""" """
client = boto3.client("athena") client = boto3.client("athena")
client.output_location = output_location client.output_location = output_location
client.database_name = database_name
query( query(
client, client,
create_database(database_name), create_database(database_name),
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment