Dump to db

kolzchut · Jun 5, 2024 · e64f6f4 · e64f6f4
1 parent 586483d
commit e64f6f4
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/operators/derive/__init__.py b/operators/derive/__init__.py
@@ -1,4 +1,4 @@
-from . import to_dp, to_es, to_mapbox, to_sitemap, from_curation, autocomplete
+from . import to_dp, to_es, to_mapbox, to_sitemap, from_curation, autocomplete, to_sql
 
 from srm_tools.logger import logger
 
@@ -11,9 +11,9 @@ def operator(*_):
     to_dp.operator()
     autocomplete.operator()
     to_es.operator()
+    to_sql.operator()
     to_mapbox.operator()
     to_sitemap.operator()
-    # to_sql.operator()
 
     logger.info('Finished Derive Data Flow')
 

diff --git a/operators/derive/to_sql.py b/operators/derive/to_sql.py
@@ -28,6 +28,14 @@ def dump_to_sql_flow():
             dict(
                 cards={
                     'resource-name': 'cards',
+                    'indexes_fields': [
+                        ['service_name'],
+                        ['organization_id'],
+                        ['organization_kind'],
+                        ['branch_city'],
+                        ['national_service'],
+                        ['card_id'],
+                    ],
                 }
             ), engine='env://DATASETS_DATABASE_URL'
         ),