kflow - pypi Package Compare versions

Comparing version 1.0.147 to 1.0.148

kflow.egg-info/PKG-INFO

 Metadata-Version: 2.1
 Name: kflow
-Version: 1.0.147
+Version: 1.0.148
 Summary: KLog.co package for ETLs
@@ -5,0 +5,0 @@ Home-page: https://github.com/teu-ai/etl

kflow/authn.py

@@ -145,2 +145,5 @@ import os
     
+    elif secret_name == "data_arn_role":
+        return secret_value
+    
     elif secret_name in ["vekna_cluster","data_rds","secret-redshift-cluster-1","prisma_bd"]:
@@ -147,0 +150,0 @@ return secret_value

kflow/load.py

@@ -614,3 +614,3 @@ import logging
 
-def DataFrameCompaniesToHubspot(df:pd.DataFrame,id_field:str,hubspot_env:str="HubspotProd")  -> pd.DataFrame:
+def DataFrameCompaniesToHubspot(df:pd.DataFrame,id_field:str,hubspot_env:str="api_hubspot")  -> pd.DataFrame:
 
@@ -627,4 +627,4 @@ """Send Companies to Hubspot.
         ID Field name to recovery hubspot information
-    hubspot_env:str="HubspotProd"       
-        HubspotProd - ambiente productivo
+    hubspot_env:str="api_hubspot"       
+        api_hubspot - ambiente productivo
         HubspotTest - ambiente de pruebas       
@@ -667,3 +667,3 @@ --------------------
 
-def _UpdateCompaniesHubspot(df_hub_send:pd.DataFrame,hubspot_env:str="HubspotProd"):
+def _UpdateCompaniesHubspot(df_hub_send:pd.DataFrame,hubspot_env:str="api_hubspot"):
 
@@ -679,4 +679,4 @@ """Send Updaes (less that 100) to Companies to Hubspot.
         ****** IMPORTANT: the firts fields must be 'hs_object_id' because it's a key to match update on Hubspot ********
-    hubspot_env:str="HubspotProd"        
-        HubspotProd - ambiente productivo
+    hubspot_env:str="api_hubspot"        
+        api_hubspot - ambiente productivo
         HubspotTest - ambiente de pruebas        
@@ -716,3 +716,3 @@ --------------------
 
-def UpdateBatchCompaniesHubspot(df_hub_send:pd.DataFrame,hubspot_env:str="HubspotProd"):
+def UpdateBatchCompaniesHubspot(df_hub_send:pd.DataFrame,hubspot_env:str="api_hubspot"):
 
@@ -728,4 +728,4 @@ """Send Updaes (more that 100) to Companies to Hubspot.
         ****** IMPORTANT: the firts fields must be 'hs_object_id' because it's a key to match update on Hubspot ********
-    hubspot_env:str="HubspotProd"        
-        HubspotProd - ambiente productivo
+    hubspot_env:str="api_hubspot"        
+        api_hubspot - ambiente productivo
         HubspotTest - ambiente de pruebas       
@@ -732,0 +732,0 @@ --------------------

kflow/tools.py

@@ -207,3 +207,3 @@
 
-def read_hubspot_properties(object:str,hubspot_env:str="HubspotProd"):
+def read_hubspot_properties(object:str,hubspot_env:str="api_hubspot"):
 
@@ -256,3 +256,3 @@ import hubspot
             try:
-                logging.info(f"Deploying {table} staging to public")
+                logging.info(f"Deploying {table} {source_shema} to {target_shema}")
                 logging.info(f"Verifying...")                    
@@ -279,3 +279,3 @@ warehouse_engine.execute(f"select * from {source_shema}.{table} limit 1")
             try:
-                logging.info(f"Deploying {table} {source_shema} to public") 
+                logging.info(f"Deploying {table} {source_shema} to {target_shema}") 
                 logging.info(f"Verifying...")                   
@@ -293,9 +293,3 @@ warehouse_engine.execute(f"select * from {source_shema}.{table} limit 1")
             except:                
-                raise ValueError(f"{table} not deploy")
-
-    #logging.info(f"Settings grants...")    
-    #warehouse_engine.execute(f"GRANT SELECT ON ALL TABLES IN SCHEMA {target_shema} TO GROUP visualization")
-    #warehouse_engine.execute(f"GRANT SELECT ON ALL TABLES IN SCHEMA {source_shema} TO GROUP visualization")
-    #warehouse_engine.execute(f"GRANT ALL PRIVILEGES ON ALL TABLES IN SCHEMA {target_shema} TO GROUP data_dev")
-    #warehouse_engine.execute(f"GRANT ALL PRIVILEGES ON ALL TABLES IN SCHEMA {source_shema} TO GROUP data_dev")                  
+                raise ValueError(f"{table} not deploy")                
     sleep(2)
@@ -302,0 +296,0 @@

PKG-INFO

 Metadata-Version: 2.1
 Name: kflow
-Version: 1.0.147
+Version: 1.0.148
 Summary: KLog.co package for ETLs
@@ -5,0 +5,0 @@ Home-page: https://github.com/teu-ai/etl

Alert delta unavailable

Currently unable to show alert delta for PyPI packages.

Worsened metrics

Total package byte prevSize

93540

-0.42%

Lines of code

1823

-0.16%