From b26b05dc29c7d16ba480c82bd48184bc6f60af50 Mon Sep 17 00:00:00 2001 From: pixuimpou <74972217+pixuimpou@users.noreply.github.com> Date: Wed, 27 Mar 2024 16:03:20 +0000 Subject: [PATCH] =?UTF-8?q?Deploying=20to=20gh-pages=20from=20@=20prefeitu?= =?UTF-8?q?ra-rio/pipelines@8ea483cedb89666d01358a3358671935e6b0f120=20?= =?UTF-8?q?=F0=9F=9A=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rj_smtr/constants.html | 39 +++++++++++++++++++++++++-------------- rj_smtr/tasks.html | 4 ++-- 2 files changed, 27 insertions(+), 16 deletions(-) diff --git a/rj_smtr/constants.html b/rj_smtr/constants.html index ebd4cc79d..cf465932d 100644 --- a/rj_smtr/constants.html +++ b/rj_smtr/constants.html @@ -817,7 +817,7 @@

Module pipelines.rj_smtr.constants

fiscalizacao WHERE dt_inclusao >= '{start}' - dt_inclusao < '{end}' + AND dt_inclusao < '{end}' """, }, "primary_key": ["id"], @@ -1172,26 +1172,29 @@

Module pipelines.rj_smtr.constants

BILHETAGEM_EXCLUDE = "+operadoras +consorcios" + BILHETAGEM_JAE_DASHBOARD_DATASET_ID = "dashboard_bilhetagem_jae" + BILHETAGEM_MATERIALIZACAO_INTEGRACAO_PARAMS = { - "dataset_id": BILHETAGEM_DATASET_ID, - "table_id": "integracao", + "dataset_id": BILHETAGEM_JAE_DASHBOARD_DATASET_ID, + "table_id": "view_integracao", "upstream": True, "dbt_vars": { "date_range": { - "table_run_datetime_column_name": "datetime_captura", + "table_run_datetime_column_name": "data", "delay_hours": 0, }, "version": {}, }, - "exclude": BILHETAGEM_EXCLUDE, + "exclude": f"{BILHETAGEM_EXCLUDE} stops_gtfs2 routes_gtfs2 feed_info_gtfs2", } BILHETAGEM_MATERIALIZACAO_TRANSACAO_PARAMS = { - "dataset_id": "dashboard_bilhetagem_jae", + "dataset_id": BILHETAGEM_JAE_DASHBOARD_DATASET_ID, + "table_id": "view_passageiros_hora", "upstream": True, "dbt_vars": { "date_range": { - "table_run_datetime_column_name": "datetime_transacao", + "table_run_datetime_column_name": "data", "delay_hours": 1, }, "version": {}, @@ -2299,7 +2302,7 @@

Classes

fiscalizacao WHERE dt_inclusao >= '{start}' - dt_inclusao < '{end}' + AND dt_inclusao < '{end}' """, }, "primary_key": ["id"], @@ -2654,26 +2657,29 @@

Classes

BILHETAGEM_EXCLUDE = "+operadoras +consorcios" + BILHETAGEM_JAE_DASHBOARD_DATASET_ID = "dashboard_bilhetagem_jae" + BILHETAGEM_MATERIALIZACAO_INTEGRACAO_PARAMS = { - "dataset_id": BILHETAGEM_DATASET_ID, - "table_id": "integracao", + "dataset_id": BILHETAGEM_JAE_DASHBOARD_DATASET_ID, + "table_id": "view_integracao", "upstream": True, "dbt_vars": { "date_range": { - "table_run_datetime_column_name": "datetime_captura", + "table_run_datetime_column_name": "data", "delay_hours": 0, }, "version": {}, }, - "exclude": BILHETAGEM_EXCLUDE, + "exclude": f"{BILHETAGEM_EXCLUDE} stops_gtfs2 routes_gtfs2 feed_info_gtfs2", } BILHETAGEM_MATERIALIZACAO_TRANSACAO_PARAMS = { - "dataset_id": "dashboard_bilhetagem_jae", + "dataset_id": BILHETAGEM_JAE_DASHBOARD_DATASET_ID, + "table_id": "view_passageiros_hora", "upstream": True, "dbt_vars": { "date_range": { - "table_run_datetime_column_name": "datetime_transacao", + "table_run_datetime_column_name": "data", "delay_hours": 1, }, "version": {}, @@ -3013,6 +3019,10 @@

Class variables

+
var BILHETAGEM_JAE_DASHBOARD_DATASET_ID
+
+
+
var BILHETAGEM_MATERIALIZACAO_GPS_VALIDADOR_GENERAL_PARAMS
@@ -3515,6 +3525,7 @@

BILHETAGEM_GENERAL_CAPTURE_DEFAULT_PARAMS
  • BILHETAGEM_GENERAL_CAPTURE_PARAMS
  • BILHETAGEM_INTEGRACAO_CAPTURE_PARAMS
    • +
  • BILHETAGEM_JAE_DASHBOARD_DATASET_ID
  • BILHETAGEM_MATERIALIZACAO_GPS_VALIDADOR_GENERAL_PARAMS
  • BILHETAGEM_MATERIALIZACAO_GPS_VALIDADOR_TABLE_ID
  • BILHETAGEM_MATERIALIZACAO_GPS_VALIDADOR_VAN_TABLE_ID
    • diff --git a/rj_smtr/tasks.html b/rj_smtr/tasks.html index 1bfb50d0d..454e3788b 100644 --- a/rj_smtr/tasks.html +++ b/rj_smtr/tasks.html @@ -220,7 +220,7 @@

    Module pipelines.rj_smtr.tasks

    # Create date_range using Redis else: if not table_id: - log("table_id are blank. Skiping task...") + log("table_id is blank. Skiping task...") return [None], None, False raw_table_id = raw_table_id or table_id @@ -2077,7 +2077,7 @@

    Returns

    # Create date_range using Redis else: if not table_id: - log("table_id are blank. Skiping task...") + log("table_id is blank. Skiping task...") return [None], None, False raw_table_id = raw_table_id or table_id