feat(native): Cube.py - introduce config decorator (#7131)

Author: ovr

packages/cubejs-backend-native/python/cube/src/conf/__init__.py

@@ -21,6 +21,8 @@ def file_repository(path):
 
     return files
 
+class ConfigurationException(Exception):
+    pass
 
 class RequestContext:
     url: str
@@ -157,3 +159,12 @@ def set_pre_aggregations_schema(self, pre_aggregations_schema: Callable[[Request
 
 
 settings = Configuration()
+
+def config(func):
+    if not callable(func):
+        raise ConfigurationException("@config decorator must be used with functions, actual: '%s'" % type(func).__name__)
+
+    if hasattr(settings, func.__name__):
+        setattr(settings, func.__name__, func)
+    else:
+        raise ConfigurationException("Unknown settings property: '%s'" % func.__name__)

packages/cubejs-backend-native/test/config.py

@@ -1,4 +1,5 @@
 from cube.conf import (
+    config,
     settings,
     file_repository
 )
@@ -7,27 +8,22 @@
 settings.pg_sql_port = 5555
 settings.telemetry = False
 
+@config
 def query_rewrite(query, ctx):
     print('[python] query_rewrite query=', query, ' ctx=', ctx)
     return query
 
-settings.query_rewrite = query_rewrite
-
+@config
 async def check_auth(req, authorization):
     print('[python] check_auth req=', req, ' authorization=', authorization)
 
-
-settings.check_auth = check_auth
-
+@config
 async def repository_factory(ctx):
     print('[python] repository_factory ctx=', ctx)
 
     return file_repository(ctx['securityContext']['schemaPath'])
 
-settings.repository_factory = repository_factory
-
+@config
 async def context_to_api_scopes():
     print('[python] context_to_api_scopes')
     return ['meta', 'data', 'jobs']
-
-settings.context_to_api_scopes = context_to_api_scopes

packages/cubejs-backend-native/test/scoped-config.py

@@ -1,27 +1,26 @@
 source_code = """
-from cube.conf import settings
+from cube.conf import (
+    settings,
+    config
+)
 
 settings.schema_path = "models"
 settings.pg_sql_port = 5555
 settings.telemetry = False
 
+@config
 def query_rewrite(query, ctx):
     print('[python] query_rewrite query=', query, ' ctx=', ctx)
     return query
 
-settings.query_rewrite = query_rewrite
-
+@config
 async def check_auth(req, authorization):
     print('[python] check_auth req=', req, ' authorization=', authorization)
 
-
-settings.check_auth = check_auth
-
+@config
 async def context_to_api_scopes():
     print('[python] context_to_api_scopes')
     return ['meta', 'data', 'jobs']
-
-settings.context_to_api_scopes = context_to_api_scopes
 """
 
 __execution_context_globals = {}