Update 31-07-23. Update README

dags/components/Generation.py

@@ -8,6 +8,7 @@ from airflow.decorators import task
 from airflow.exceptions import AirflowSkipException
 
 from enums.ProcessStatusEnum import ProcessStatusEnum
+from enums.DatabaseTypeEnum import DatabaseTypeEnum
 from components.S3Route import save_df_to_s3, load_obj_to_s3
 from components.Utils import select_multiple, create_temp_file, delete_temp_dir
 from components.Control import get_tasks_from_control, update_new_process
@@ -90,8 +91,11 @@ def generate_and_deploy(command: str, intern_conn, params: Dict[str, Any], timez
     delimiter = params["delimiter"]
     tmp_path = params["tmp_path"]
     tmp_file = create_temp_file(tmp_path, filename_mask, file_type, tablename, timezone, pattern)
-    logger.info(tmp_file)
+    logger.info(f"Ruta creada: {tmp_file}")
+    logger.debug(f"TABLA: {tablename}")
     steps = get_steps(tablename, chunksize, engine, True)
+    if intern_conn.db_type == DatabaseTypeEnum.ORACLE.value:
+        tablename = f"SELECT * FROM {tablename}"
     iterator = get_iterator(tablename, chunksize, engine)
     logger.info(f"Total de pasos para generar archivo resultado: {steps}")
     for step in range(steps):