diff --git a/dagger/dag_creator/airflow/operators/postgres_operator.py b/dagger/dag_creator/airflow/operators/postgres_operator.py
index b833516..c01b255 100644
--- a/dagger/dag_creator/airflow/operators/postgres_operator.py
+++ b/dagger/dag_creator/airflow/operators/postgres_operator.py
@@ -51,6 +51,6 @@ def execute(self, context):
         self.hook = PostgresHook(
             postgres_conn_id=self.postgres_conn_id, schema=self.database
         )
-        self.hook.run(self.sql, self.autocommit, parameters=self.parameters)
+        self.hook.run(self.sql, self.autocommit, parameters=self.parameters, split_statements=True)
         for output in self.hook.conn.notices:
             self.log.info(output)