configure streams based on settings

druids · Jan 11, 2022 · bf616a2 · bf616a2
1 parent b6ae54f
commit bf616a2
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 = {