safely convert ini parameters to bool, int, list and dict

.gitlab-ci.yml

@@ -0,0 +1,49 @@
+image: python:latest
+
+variables:
+  PIP_CACHE_DIR: "$CI_PROJECT_DIR/.cache/pip"
+  #
+  PUBLIC_REGISTRY_PROJECT_ID: 32304092
+
+cache:
+  paths:
+    - .cache/pip
+    - venv/
+
+stages:
+  - check
+  - deploy
+
+before_script:
+  - python -V  # Print out python version for debugging
+
+ruff:
+  stage: check
+  script:
+    - pip install ruff
+    - ruff check --output-format=gitlab --output-file gl-code-quality-report.json pyramid_celery
+  artifacts:
+    reports:
+      codequality: gl-code-quality-report.json
+
+# test:
+#   script:
+#     - pip install .
+#     - flake8 --exit-zero --format gl-codeclimate --output-file examples-report.json --tee examples/
+#     - python -m json.tool < examples-report.json
+
+deploy_local:
+  stage: deploy
+  script:
+    - env
+    - pip install twine build
+    - python -m build -w
+    - TWINE_PASSWORD=${CI_JOB_TOKEN} TWINE_USERNAME=gitlab-ci-token python -m twine upload --repository-url ${CI_API_V4_URL}/projects/${CI_PROJECT_ID}/packages/pypi dist/*
+
+deploy_public:
+  stage: deploy
+  script:
+    - env
+    - pip install twine build
+    - python -m build -w
+    - TWINE_PASSWORD=${CI_JOB_TOKEN} TWINE_USERNAME=gitlab-ci-token python -m twine upload --repository-url ${CI_API_V4_URL}/projects/${PUBLIC_REGISTRY_PROJECT_ID}/packages/pypi dist/*

pyramid_celery/loaders.py

@@ -1,5 +1,7 @@
 import datetime
 import json
+import pyjson5 as json5
+from pyjson5 import Json5DecoderException as JSONDecodeError
 import celery.loaders.base
 import celery.schedules
 import configparser
@@ -91,6 +93,25 @@ def get_route_config(parser, section):
     return config
 
 
+def safe_conversion(value):
+    """convert a string to a more specific type"""
+    try:
+        newval= json5.loads(value)
+        #print("JSON DECODED", type(newval),  newval)
+        return newval
+    except JSONDecodeError:
+        pass
+
+    if value.lower() in ("true", "false"):
+        return bool(value)
+    try:
+        if float(value).is_integer():
+            return int(value)
+        return float(value)
+    except ValueError:
+        return value
+
+
 class INILoader(celery.loaders.base.BaseLoader):
     ConfigParser = configparser.SafeConfigParser
 
@@ -106,7 +127,7 @@ def read_configuration(self, fail_silently=True):
         config_dict = {}
 
         for key, value in self.parser.items('celery'):
-            config_dict[key] = value
+            config_dict[key] = safe_conversion(value)
 
         if celery_version.major > 6:
             # TODO: Check for invalid settings

setup.py

@@ -9,7 +9,7 @@
 requires = ['pyramid', 'celery']
 
 setup(name='pyramid_celery',
-      version='4.0.0',
+      version='4.0.3',
       description='Celery integration with pyramid',
       long_description=README + "\n" + CHANGES,
       classifiers=[