Merge pull request #1423 from sul-dlss/t1419-oclc-dag-schedule

Remove scheduling, catchup, and start-date from OCLC DAGs

libsys_airflow/dags/data_exports/oclc_selections.py

@@ -7,9 +7,7 @@
 from airflow.models.param import Param
 from airflow.operators.python import BranchPythonOperator
 from airflow.operators.empty import EmptyOperator
-from airflow.models import Variable
 from airflow.operators.python import PythonOperator
-from airflow.timetables.interval import CronDataIntervalTimetable
 
 from libsys_airflow.plugins.data_exports.instance_ids import (
     choose_fetch_folio_ids,
@@ -48,11 +46,7 @@
 with DAG(
     "select_oclc_records",
     default_args=default_args,
-    schedule=CronDataIntervalTimetable(
-        cron=Variable.get("select_oclc", "30 1 * * *"), timezone="America/Los_Angeles"
-    ),
-    start_date=datetime(2024, 2, 25),
-    catchup=False,
+    schedule=None,
     tags=["data export", "oclc"],
     params={
         "from_date": Param(

libsys_airflow/dags/data_exports/oclc_transmission.py

@@ -1,10 +1,8 @@
 import logging
-from datetime import datetime, timedelta
+from datetime import timedelta
 
 from airflow.decorators import dag, task, task_group
-from airflow.models import Variable
 from airflow.operators.empty import EmptyOperator
-from airflow.timetables.interval import CronDataIntervalTimetable
 
 from libsys_airflow.plugins.data_exports.transmission_tasks import (
     archive_transmitted_data_task,
@@ -51,13 +49,8 @@
 
 @dag(
     default_args=default_args,
-    schedule=CronDataIntervalTimetable(
-        cron=Variable.get("transmit_oclc", "30 3 * * FRI"),
-        timezone="America/Los_Angeles",
-    ),
-    start_date=datetime(2024, 1, 1),
-    catchup=False,
     tags=["data export", "oclc"],
+    schedule=None,
 )
 def send_oclc_records():
     start = EmptyOperator(task_id="start")