I want to scrape a website daily by using AirFlow and Selenium Grid server. I have created a single DAG for this.
The website provide an endpoint (e.g. website.com/python, website.com/java, website.com/ruby) for each data in a same web user interface.
I've succesfully triggered The DAG by using AirFlow REST API with a conf variable. Now I want to schedule every run, which I have triggered, daily with the coressponding conf variable.
Is it possible to achieve this (maybe by creating a new DAG or dynamically set a cronjob) ?
Schedule a DAG at different time by using Airflow REST API with conf variables
162 Views Asked by Jooo21 At
1
There are 1 best solutions below
Related Questions in CRON
- is there a solution to run cron job command in cpanel only from my cPanel host?
- crontab run every minute after 9pm
- Python3.11 can't open file [Errno 2] No such file or directory
- Overwhelming of the Agenda cron jobs on the server
- How to schedule cron job in spring boot to run for every 5 minutes with in specific period
- Building a service which sends emails everyday to the user at a particular time. (NOT RUNNING)
- Extend function execution on product update via a Cron Job or REST_API
- Activity status in Node js
- Azure YAML Pipeline schedule to run on the last Sunday of the month at 4 AM
- Run scheduler on authenticated api
- I would like to Create a schedule in Databricks that runs a job on 1st working day of every month
- Add and Replace Jobs in Crontab
- Moodle Forum notifctions
- python3 working on terminal but not on cron job
- Context Deadline exceeded and WebSocket Url timeout issue
Related Questions in AIRFLOW
- Troubleshooting Airflow Task Failures: Slack Notification Timeout
- I want to monitor a job triggered through emrserverlessstartjoboperator. If the job is either is success or failed, want to rerun the job in airflow
- How to Resolve Workers Not Scaling with 100s of Queued Tasks in Google Cloud Composer?
- Task failure in DataprocCreateClusterOperator when i add metadata
- Load data from csv in airflow docker container to snowflake DB
- Task grouping in Airflow
- Extending Airflow DAG class - is this a bad practice?
- Elasticsearch - cascading http inputs from Airflow API
- Apache Airflow sparksubmit
- airflow dags not running as expected
- Create a daily DAG that will run for multiple days
- Transform Load pipeline for a logs system: Apache Airflow or Kafka Connect?
- My initial tasks are queued for 30-40 sec (very long in my case)
- Airflow config for running concurrent DAG tasks
- Airflow, FastAPI and postgres: host with docker
Related Questions in CRON-TASK
- When i implement Cronejob it looks like doesn't take effect
- Setting up a Cron Job to Trigger on the Y-th Day Every Month, Handling Non-Existent Dates
- On MacOS: Is there a way to let Python Create Cron Tasks without Security Prompt?
- Crontab fails but command works in terminal
- agenda dynamic job through api endpoint
- Starting a Blazor Server with Crontab on reboot on RPi
- Quartz scheduler job schedules more than 1 cron job
- Schedule a DAG at different time by using Airflow REST API with conf variables
- Use WooCommerce WC_Order object with wp_schedule_event
- Cron inside Docker container with python script problem
- Cronjob stopped working after apt-update/ apt-upgrade
- Cronos Job - Issue when Weekend happens to be first day of the month
- Cron issue between every minute setup and specific time setup
- Coordinating 2 Node JS Cron Jobs and other tasks sequentially
- How to horizontally scale scheduler application which can dynamically create and delete cron schedules
Related Questions in AIRFLOW-API
- How to Enable Basic Authentication (user& password) to apache airflow(2.8.1) API
- In Airflow Pool Dagrun status is scheduled but in List Dag Run Dagrun status is running
- connection between airflow and vault
- from airflow.providers.amazon.transfers.local_to_s3 import LocalToS3Operator ModuleNotFoundError: No module 'airflow.providers.amazon.transfers'
- Is there any way to get config parameters in Bash operator, when we run dag manually (like we have for Python kwargs)
- Airflow using @task and @task_group along with operators other than python callable
- Creating json variable with Airflow web API
- openmetadata/ingestion Environment variables not working properly
- Airflow Dag run goes into queue
- Schedule a DAG at different time by using Airflow REST API with conf variables
- Airflow: from connexion.decorators.validation import RequestBodyValidator ModuleNotFoundError: No module named 'connexion.decorators.validation'
- How to trigger an Airflow DAG via API using curl
- How to clear the DagRun object (<DagRun dag_id@2023-01-01 00:15:00+00:00:scheduled__2023-01-01T00:15:00+00:00, externally triggered: False>)
- Get dag_ids from airflow on which task is running
- Query Airflow XCom table with value column filter
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular # Hahtags
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
You can schedule an Airflow DAG by setting
scheduleon theDAG, for example:From your question, it's unclear to me if your conf changes per DAG run. If not, you could hardcode all the settings, or set them through
paramson the DAG, see example here.