Skip to content

Commit c6c4d89

Browse files
authored
docs(demo/airflow-scheduled-job): Update instructions (#378)
* docs(demo/airflow-scheduled-job): Simplify install Otherwise it makes the rest of the demo confusing * docs(demo/airflow-scheduled-job): Update instructions
1 parent 05b5f2a commit c6c4d89

File tree

1 file changed

+9
-8
lines changed

1 file changed

+9
-8
lines changed

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

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,11 @@
33

44
Install this demo on an existing Kubernetes cluster:
55

6-
[source,console]
7-
----
8-
$ stackablectl demo install airflow-scheduled-job
9-
----
10-
11-
You can also deploy it to a specific namespace (the namespace `airflow-demo` will be assumed in this guide):
6+
[NOTE]
7+
====
8+
The namespace `airflow-demo` will be assumed in this guide.
9+
It will be created if it doesn't exist.
10+
====
1211

1312
[source,console]
1413
----
@@ -225,7 +224,7 @@ image::airflow-scheduled-job/airflow_17.png[]
225224

226225
Click on the DAG, switching to the task view.
227226
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.
228-
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:
229228

230229
image::airflow-scheduled-job/deferrable_01_running.png[]
231230
image::airflow-scheduled-job/deferrable_02_queued.png[]
@@ -315,13 +314,15 @@ spec:
315314
envOverrides: *envOverrides
316315
----
317316

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

320319
[source,console]
321320
----
322321
kubectl patch airflowcluster airflow --type="merge" --patch-file stacks/airflow/patch_airflow.yaml -n airflow-demo
323322
----
324323

324+
Wait for Airflow to come back up, and you should now see the generated DAGs.
325+
325326
[NOTE]
326327
====
327328
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)