ensure internal id string

taxonomies/trees/process.py

@@ -92,29 +92,16 @@ def postflow(self):
         )
 
 
-class EnsureInternalIdString(BaseEnricher):
+class EnsureInternalIdString(ColumnTypeTester):
 
-    FIELD_NAME = 'meta-internal-id',
-
-    def test(self):
-        return True
-
-    def fix_internal_id(self):
-        def predicate():
-            def func(dp):
-                all_fields = [f['name'] for f in dp.descriptor['resources'][0]['schema']['fields']]
-                return self.FIELD_NAME in all_fields
-            return func
-        return DF.conditional(
-            predicate(),
-            DF.Flow(
-                DF.set_type(self.FIELD_NAME, type='number', transform=lambda x: str(x) if x is not None else None)
-            )
-        )
+    REQUIRED_COLUMN_TYPES = [
+        'meta:internal-id',
+    ]
+    PROHIBITED_COLUMN_TYPES = []
 
-    def postflow(self):
+    def conditional(self):
         return DF.Flow(
-            self.fix_internal_id(),
+            DF.set_type('meta-internal-id', type='string', transform=lambda v: str(v) if v is not None else None)
         )