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
- s3cmd not working as cron-task when echos/dates are added
- Run private Python script on Google Cloud Platform
- Rails Fetch record from instagram using cron job
- scheduling with cronjob to run the php file for only one time
- wp_schedule_event hook scheduled but not working
- Handling error in CronJob executing function
- Laravel not running jobs
- Plesk 12 Schedule Task, Manually Force Email on Error
- How to create a CRON job which runs a bazel command
- Nested cron job stop and start issue
- How to design a distributed job scheduler?
- Active cron job
- Cron job sends every minute instead of specefic time
- How to download attachement to the server using bluehost cron job
- spring cron jobs sceduler , monthly basis
Related Questions in AIRFLOW-API
- 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>)
- How to trigger an Airflow DAG via API using curl
- Airflow: from connexion.decorators.validation import RequestBodyValidator ModuleNotFoundError: No module named 'connexion.decorators.validation'
- Schedule a DAG at different time by using Airflow REST API with conf variables
- Airflow Dag run goes into queue
- openmetadata/ingestion Environment variables not working properly
- Creating json variable with Airflow web API
- Is there any way to get config parameters in Bash operator, when we run dag manually (like we have for Python kwargs)
- How to get reason for failure using slack in airflow2.0
- How to connect MWAA CLI that is hosted in a public subnet
- Airflow 2: Check if a task still exists or not with task_id
- Hitting the Airflow API running on Astronomer cloud
- Is it safe to delete airflow.db file?
- How to trigger airflow dag with REST API (I get "Property is read-only - 'state'", error)
- Accessing Airflow REST API in AWS Managed Workflows?
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 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.