Skip to content

Commit 62e72a3

Browse files
committed
docs(demo/airflow-scheduled-job): Update instructions
1 parent 797b684 commit 62e72a3

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

docs/modules/demos/pages/airflow-scheduled-job.adoc

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -224,7 +224,7 @@ image::airflow-scheduled-job/airflow_17.png[]
224224

225225
Click on the DAG, switching to the task view.
226226
This DAG uses a deferrable operator which, in conjunction with the triggerer process, "offloads" the DAG from its worker for a specfic period of time, before being picked up and again and executed.
227-
You will see the task cycle through the following states:
227+
From the Task Instances view (under Dags), you will see the task cycle through the following states:
228228

229229
image::airflow-scheduled-job/deferrable_01_running.png[]
230230
image::airflow-scheduled-job/deferrable_02_queued.png[]
@@ -314,13 +314,15 @@ spec:
314314
envOverrides: *envOverrides
315315
----
316316

317-
THe patch can be applied like this:
317+
The patch can be applied like this:
318318

319319
[source,console]
320320
----
321321
kubectl patch airflowcluster airflow --type="merge" --patch-file stacks/airflow/patch_airflow.yaml -n airflow-demo
322322
----
323323

324+
Wait for Airflow to come back up, and you should now see the generated DAGs.
325+
324326
[NOTE]
325327
====
326328
The scheduled job runs every minute and so an instance of it may be running while the scheduler is being re-started as a result of the patch, in which case that instance may fail.

0 commit comments

Comments
 (0)