diff --git a/target_s3_parquet/sinks.py b/target_s3_parquet/sinks.py
index d711689..91fed41 100644
--- a/target_s3_parquet/sinks.py
+++ b/target_s3_parquet/sinks.py
@@ -37,6 +37,8 @@ def __init__(
 
         self._glue_schema = self._get_glue_schema()
 
+        wr.catalog.create_database(self.config.get("athena_database"), exist_ok=True)
+
     def _get_glue_schema(self):
 
         catalog_params = {