Merge pull request #9 from jsilhan/enable-streams

configure streams based on settings
druids · Jan 19, 2022 · 368b1f0 · 368b1f0
2 parents b6ae54f + bf616a2
commit 368b1f0
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pydjamodb/connection.py b/pydjamodb/connection.py
@@ -71,6 +71,8 @@ def create_table(self,
             settings.PYDJAMODB_DATABASE.get('POINT_IN_TIME_RECOVERY', False) if set_point_in_time_recovery is None
             else set_point_in_time_recovery
         )
+        if not stream_specification:
+            stream_specification = settings.PYDJAMODB_DATABASE.get('STREAM_SPECIFICATION')
 
         if tags is None and 'TAGS' in settings.PYDJAMODB_DATABASE:
             tags = {