Updated fixtures with new fields for tests

The-Academic-Observatory · Sep 15, 2023 · 04ba403 · 04ba403
1 parent b20041f
commit 04ba403
Show file tree

Hide file tree

Showing 7 changed files with 13 additions and 13 deletions.
diff --git a/academic_observatory_workflows/database/schema/openalex/works.json b/academic_observatory_workflows/database/schema/openalex/works.json
@@ -12,7 +12,7 @@
       {
         "name": "InvertedIndex",
         "type": "RECORD",
-        "mode": "REPEATED",
+        "mode": "NULLABLE",
         "fields": [
           {
             "name": "keys",

diff --git a/...y_workflows/fixtures/openalex/2023-04-02/data/works/updated_date=2023-04-02/part_000.json b/...y_workflows/fixtures/openalex/2023-04-02/data/works/updated_date=2023-04-02/part_000.json
diff --git a/academic_observatory_workflows/fixtures/openalex/2023-04-02/expected/works.json b/academic_observatory_workflows/fixtures/openalex/2023-04-02/expected/works.json
diff --git a/...y_workflows/fixtures/openalex/2023-04-16/data/works/updated_date=2023-04-02/part_000.json b/...y_workflows/fixtures/openalex/2023-04-16/data/works/updated_date=2023-04-02/part_000.json
diff --git a/...y_workflows/fixtures/openalex/2023-04-16/data/works/updated_date=2023-04-16/part_000.json b/...y_workflows/fixtures/openalex/2023-04-16/data/works/updated_date=2023-04-16/part_000.json
diff --git a/academic_observatory_workflows/fixtures/openalex/2023-04-16/expected/works.json b/academic_observatory_workflows/fixtures/openalex/2023-04-16/expected/works.json
diff --git a/academic_observatory_workflows/workflows/openalex_telescope.py b/academic_observatory_workflows/workflows/openalex_telescope.py
@@ -31,7 +31,7 @@
 import pendulum
 from airflow.hooks.base import BaseHook
 from airflow.models.taskinstance import TaskInstance
-from airflow.operators.empty import EmptyOperator as DummyOperator
+from airflow.operators.empty import EmptyOperator
 from google.cloud import bigquery
 from google.cloud.bigquery import SourceFormat
 
@@ -399,7 +399,7 @@ def __init__(
 
         # The last task that the next DAG run's ExternalTaskSensor waits for.
         self.add_operator(
-            DummyOperator(
+            EmptyOperator(
                 task_id=external_task_id,
             )
         )