Merge pull request #27 from socialpoint-labs/feature/isolation-config…

…-extension

Add isolation configuration extension by connection variables

sqlbucket/__init__.py

@@ -1,6 +1,6 @@
 
 
-__version__ = "0.4.0"
+__version__ = "0.4.1"
 
 
 from sqlbucket.core import SQLBucket

sqlbucket/cli.py

@@ -55,10 +55,8 @@ def run_job(sqlbucket, name, db, fstep, tstep, to_date, from_date,
         logger.info('Variables used')
         logger.info(submitted_variables)
 
-        if isolation:
-            isolation = isolation.upper()
-
         # included dbs
+        dbs = list()
         if db:
             dbs = db.split(',')
         elif all:
@@ -72,6 +70,10 @@ def run_job(sqlbucket, name, db, fstep, tstep, to_date, from_date,
             dbs = [item for item in dbs if item not in ex_dbs]
 
         for dbi in dbs:
+            connection_variables = sqlbucket.connection_variables[dbi]
+            if 'isolation_level' in connection_variables and isolation is None:
+                isolation = connection_variables['isolation_level']
+
             etl = sqlbucket.load_project(
                 project_name=name,
                 connection_name=dbi,
@@ -80,6 +82,9 @@ def run_job(sqlbucket, name, db, fstep, tstep, to_date, from_date,
             if rendering:
                 etl.render(from_step=fstep, to_step=tstep, group=group)
             else:
+                if isolation:
+                    isolation = isolation.upper()
+
                 etl.run(
                     from_step=fstep,
                     to_step=tstep,