Release 0.6.12 (#260)

CHANGELOG.md

@@ -1,5 +1,16 @@
 # Change Log
 
+## [0.6.12] - 2024-01-19
+
+### Changed
+
+- Snowflake: temporary objects are created as `temp` where possible
+  (ie: stages, incremental tables,...)
+- Added flag to run command (--with-tests) that combines the execution of
+  both tests and tasks
+- Added new flag to run and test commands (--fail-fast) that terminates the
+  execution upon an error on any task or test
+
 ## [0.6.11] - 2023-08-30
 
 ### Fixed

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "sayn"
-version = "0.6.11"
+version = "0.6.12"
 description = "Data-modelling and processing framework for automating Python and SQL tasks"
 authors = ["Sotiris Gkoulimaris <[email protected]>", "Adrian Macias <[email protected]>"]
 license = "Apache-2.0"

sayn/__init__.py

@@ -5,7 +5,7 @@
 # except:
 #     pass
 
-__version__ = "0.6.11"
+__version__ = "0.6.12"
 
 
 from .tasks.python import PythonTask, task

sayn/tasks/sql.py

@@ -441,6 +441,8 @@ def execute(self, execute, debug):
         return Ok()
 
     def compile(self):
+        if self.run_arguments["with_tests"] and self._has_tests:
+            self.write_compilation_output(self.test_query, "test")
         return self.execute(False, self.run_arguments["debug"])
 
     def run(self):

sayn/tasks/task_wrapper.py

@@ -386,8 +386,6 @@ def execute_task(self, command):
                         result = self.runner.test()
                 elif command == "compile":
                     result = self.runner.compile()
-                    if self.run_arguments["with_tests"] and self.has_tests():
-                        result = self.runner.test()
                 else:
                     result = self.runner.test()
 

sayn/tasks/test.py

@@ -133,6 +133,10 @@ def config_macro(self, **config):
         # Returns an empty string to avoid productin incorrect sql
         return ""
 
+    def compile(self):
+        with self.step("Write Test Query"):
+            self.write_compilation_output(self.test_query, "test")
+
     def setup(self):
         if self.needs_recompile:
             self.test_query = self.compiler.compile(self.task_config.file_name)