Merge pull request #351 from basedosdados/staging/update_metadata

fix: fixing flow
basedosdados · Jul 13, 2023 · b9b2706 · b9b2706
2 parents a06fc0c + 8053d9e
commit b9b2706
Show file tree

Hide file tree

Showing 4 changed files with 2 additions and 22 deletions.
diff --git a/pipelines/utils/tasks.py b/pipelines/utils/tasks.py
@@ -30,6 +30,7 @@
 )
 from typing import Tuple
 
+
 @task
 def log_task(msg: Any, level: str = "info"):
  """

diff --git a/pipelines/utils/temporal_coverage_updater/constants.py b/pipelines/utils/temporal_coverage_updater/constants.py
@@ -10,6 +10,3 @@ class constants(Enum): # pylint: disable=c0103
  """
  Constant values for the temporal_coverage_updater project
  """
-
- EMAIL = "email"
- PASSWORD = "pass"
diff --git a/pipelines/utils/temporal_coverage_updater/flows.py b/pipelines/utils/temporal_coverage_updater/flows.py
@@ -29,8 +29,7 @@
  dataset_id,
  table_id,
  metadata_type="DateTimeRange",
- bq_last_update=False,
- _last_date="2030-01-01",
+ bq_last_update=True,
  )
  # (email, password) = get_credentials(secret_path="api_user_prod")
  # ids = find_ids(

diff --git a/pipelines/utils/temporal_coverage_updater/schedules.py b/pipelines/utils/temporal_coverage_updater/schedules.py
@@ -2,20 +2,3 @@
 """
 Schedules for temporal_coverage_updater
 """
-
-from datetime import timedelta, datetime
-from prefect.schedules import Schedule
-from prefect.schedules.clocks import IntervalClock
-from pipelines.constants import constants
-
-every_two_weeks = Schedule(
- clocks=[
- IntervalClock(
- interval=timedelta(weeks=2),
- start_date=datetime(2021, 1, 1),
- labels=[
- constants.DATASETS_AGENT_LABEL.value,
- ],
- ),
- ]
-)