- Corrección mínima de errores

conector.py

@@ -163,9 +163,9 @@ def refrescar_datos_adicionales(conjunto = 'COVID-19'):
 	''' Refresca las vistas materializadas y las celdas de las especies '''
 
 	# Se refrescan las vistas materializadas 'snib_grid_statekm', 'snib_grid_munkm' y 'snib_grid_agebkm'
-	SESION.execute('REFRESH MATERIALIZED VIEW snib_grid_statekm')
-	SESION.execute('REFRESH MATERIALIZED VIEW snib_grid_munkm')
-	SESION.execute('REFRESH MATERIALIZED VIEW snib_grid_agebkm')
+	SESION.execute(sa.text('REFRESH MATERIALIZED VIEW snib_grid_statekm'))
+	SESION.execute(sa.text('REFRESH MATERIALIZED VIEW snib_grid_munkm'))
+	SESION.execute(sa.text('REFRESH MATERIALIZED VIEW snib_grid_agebkm'))
 	SESION.flush()
 
 	# Se actualizan los arreglos 'cells_statekm_1' de la tabla 'sp_snib'

general.py

@@ -180,7 +180,7 @@ def inicializar_dataframe(registros: List[RegistroKafka]):
 	# Se convierten los campos de fecha a datetime
 	df['FECHA_ACTUALIZACION'] = pd.to_datetime(df['FECHA_ACTUALIZACION'])
 	df['FECHA_SINTOMAS'] = pd.to_datetime(df['FECHA_SINTOMAS'])
-	df['FECHA_DEF'] = pd.to_datetime(df['FECHA_DEF'], format='AAAA-MM-DD', errors= 'coerce')
+	df['FECHA_DEF'] = pd.to_datetime(df['FECHA_DEF'], format= '%Y-%m-%d', errors= 'coerce')
 
 	# Se cargan los valores de las columnas de fecha de ingreso
 	df['dia_ingreso'] = df['FECHA_ACTUALIZACION'].dt.day

geolocalizacion.py

@@ -74,7 +74,7 @@ def crear_geolocalizacion(longitud: float, latitud: float):
 	# Función utilizada para asegurar que las llaves foráneas sean siempre valores enteros
 	def llave_foranea(resultado: Optional[sa.engine.Row], campo: str):
 		try:
-			return int(resultado[campo])
+			return int(getattr(resultado, campo))
 		except:
 			return 0