feat: python local evaluation implementation

.github/workflows/publish-to-pypi.yml

@@ -31,10 +31,10 @@ jobs:
         with:
           fetch-depth: 0
 
-      - name: Set up Python 3.7
+      - name: Set up Python 3.8
         uses: actions/setup-python@v3
         with:
-          python-version: 3.7
+          python-version: 3.8
 
       - name: Install dependencies
         run: python -m pip install build setuptools wheel twine amplitude_analytics parameterized python-dotenv~=0.21.1 python-semantic-release==7.34.6

.github/workflows/publish-to-test-pypi.yml

@@ -21,10 +21,10 @@ jobs:
     steps:
       - uses: actions/checkout@v3
 
-      - name: Set up Python 3.7
+      - name: Set up Python 3.8
         uses: actions/setup-python@v3
         with:
-          python-version: 3.7
+          python-version: 3.8
 
       - name: Install dependencies
         run: python -m pip install build setuptools wheel twine amplitude_analytics parameterized

.github/workflows/test.yml

@@ -8,7 +8,7 @@ jobs:
     environment: Unit Test
     strategy:
       matrix:
-        python-version: [ "3.7" ]
+        python-version: [ "3.8" ]
     steps:
       - name: Checkout source code
         uses: actions/checkout@v3

requirements-dev.txt

@@ -1,2 +1,3 @@
 parameterized~=0.9.0
 python-dotenv~=0.21.1
+requests~=2.31.0

requirements.txt

@@ -1 +1,2 @@
-amplitude_analytics~=1.1.1
+amplitude_analytics~=1.1.1
+dataclasses-json~=0.6.7

src/amplitude_experiment/deployment/deployment_runner.py

@@ -56,12 +56,12 @@ def __update_flag_configs(self):
             self.logger.warning(f'Failed to fetch flag configs: {e}')
             raise e
 
-        flag_keys = {flag['key'] for flag in flag_configs}
-        self.flag_config_storage.remove_if(lambda f: f['key'] not in flag_keys)
+        flag_keys = {flag.key for flag in flag_configs}
+        self.flag_config_storage.remove_if(lambda f: f.key not in flag_keys)
 
         if not self.cohort_loader:
             for flag_config in flag_configs:
-                self.logger.debug(f"Putting non-cohort flag {flag_config['key']}")
+                self.logger.debug(f"Putting non-cohort flag {flag_config.key}")
                 self.flag_config_storage.put_flag_config(flag_config)
             return
 
@@ -83,11 +83,11 @@ def __update_flag_configs(self):
         # iterate through new flag configs and check if their required cohorts exist
         for flag_config in flag_configs:
             cohort_ids = get_all_cohort_ids_from_flag(flag_config)
-            self.logger.debug(f"Storing flag {flag_config['key']}")
+            self.logger.debug(f"Storing flag {flag_config.key}")
             self.flag_config_storage.put_flag_config(flag_config)
             missing_cohorts = cohort_ids - updated_cohort_ids
             if missing_cohorts:
-                self.logger.warning(f"Flag {flag_config['key']} - failed to load cohorts: {missing_cohorts}")
+                self.logger.warning(f"Flag {flag_config.key} - failed to load cohorts: {missing_cohorts}")
 
         # delete unused cohorts
         self._delete_unused_cohorts()