added ql version in metadata

RELEASE_NOTES.md

@@ -5,8 +5,6 @@
 ### New features
 
 - Removed subscription API (#493)
-- Replaced geocoder with [geopy](https://geopy.readthedocs.io/en/stable/) (#610)
-- Bumped pillow from 8.4.0 to 9.0.0
 
 ### Bug fixes
 

src/_version.py

@@ -0,0 +1,6 @@
+# Most recent official release
+__version_info__ = ('0', '8', '3')
+__version__ = '.'.join(__version_info__)
+
+# Current dev version for the next release
+__dev_version__ = '0.9.0-dev'

src/reporter/tests/test_version.py

@@ -1,4 +1,5 @@
 from conftest import QL_BASE_URL
+from _version import __dev_version__
 import requests
 
 
@@ -7,5 +8,5 @@ def test_version():
     r = requests.get('{}'.format(version_url))
     assert r.status_code == 200, r.text
     assert r.json() == {
-        "version": "0.9.0-dev"
+        "version": __dev_version__
     }

src/reporter/version.py

@@ -1,6 +1,6 @@
-
+from _version import __dev_version__
 
 def version():
     return {
-        'version': '0.9.0-dev'
+        'version': __dev_version__
     }

src/translators/sql_translator.py

@@ -7,6 +7,7 @@
 from utils.common import iter_entity_attrs
 from utils.jsondict import safe_get_value
 from utils.maybe import maybe_map
+from _version import __version__
 import logging
 from geocoding.slf import SlfQuery
 import dateutil.parser
@@ -711,7 +712,8 @@ def _update_metadata_table(self, table_name, metadata):
             # Attempt to re-create metadata table
             self._create_metadata_table()
             persisted_metadata = {}
-
+
+        metadata['ql_version'] = (__version__, "Text")
         diff = metadata.keys() - persisted_metadata.keys()
         if diff:
             # we update using the difference to "not" corrupt the metadata

src/translators/tests/test_insert.py

@@ -6,6 +6,7 @@
 from translators.base_translator import BaseTranslator
 from translators.sql_translator import NGSI_TEXT, NGSI_DATETIME, NGSI_STRUCTURED_VALUE
 from utils.common import *
+from src._version import __version__
 from utils.tests.common import *
 from datetime import datetime, timezone
 
@@ -774,3 +775,24 @@ def test_ngsi_ld(translator, ngsi_ld):
     assert ngsi_ld['location']['value'] == loaded[0]['location']['values'][0]
 
     translator.clean()
+
+def expected_entity_attrs_meta_version():
+    return {
+        'entity_id': ['id', 'Text'],
+        'entity_type': ['type', 'Text'],
+        TIME_INDEX_NAME: ['time_index', 'DateTime'],
+        'ql_version': [__version__, 'Text'],
+        'a_number': ['a_number', 'Number'],
+        'an_integer': ['an_integer', 'Integer'],
+        'a_bool': ['a_bool', 'Boolean'],
+        'a_datetime': ['a_datetime', 'DateTime'],
+        'a_point': ['a_point', 'geo:point'],
+        'a_geom': ['a_geom', 'geo:json'],
+        'a_text': ['a_text', 'Text'],
+        'an_obj': ['an_obj', 'Custom'],
+        'an_array': ['an_array', 'StructuredValue']
+    }
+
+def assert_entity_attrs_meta_version(translator, entity):
+    data = select_entity_attrs_meta_version(translator, entity)
+    assert data == expected_entity_attrs_meta_version()

src/translators/tests/test_timescale_insert.py

@@ -2,6 +2,7 @@
 import pg8000
 import pytest
 import random
+from _version import __version__
 from time import sleep
 
 from geocoding.geojson.wktcodec import decode_wkb_hexstr
@@ -105,6 +106,7 @@ def expected_entity_attrs_meta():
         'entity_id': ['id', 'Text'],
         'entity_type': ['type', 'Text'],
         TIME_INDEX_NAME: ['time_index', 'DateTime'],
+        'ql_version': [__version__, 'Text'],
         'a_number': ['a_number', 'Number'],
         'an_integer': ['an_integer', 'Integer'],
         'a_bool': ['a_bool', 'Boolean'],