From 0f12e4683d4eff700e19cc698021befaa5d19b3d Mon Sep 17 00:00:00 2001
From: Lukas Bindreiter <lukas.bindreiter@tilebox.com>
Date: Mon, 7 Jul 2025 17:31:12 +0200
Subject: [PATCH] Fix automation docs

---
 workflows/near-real-time/cron.mdx           | 30 ++++++++++-----------
 workflows/near-real-time/storage-events.mdx | 18 ++++---------
 2 files changed, 19 insertions(+), 29 deletions(-)

diff --git a/workflows/near-real-time/cron.mdx b/workflows/near-real-time/cron.mdx
index 8f07207..f0f1cc3 100644
--- a/workflows/near-real-time/cron.mdx
+++ b/workflows/near-real-time/cron.mdx
@@ -40,9 +40,8 @@ client = Client()
 automations = client.automations()
 cron_automation = automations.create_cron_automation(
     "my-cron-automation",  # name of the cron automation
-    "dev-cluster",  # cluster slug to submit jobs to
     MyCronTask(message="World"),  # the task (and its input parameters) to run repeatedly
-    cron_triggers=[
+    cron_schedules=[
         "12 * * * *",  # run every hour at minute 12
         "45 18 * * *",  # run every day at 18:45
         "30 13 * * 3",  # run every Wednesday at 13:30
@@ -64,8 +63,8 @@ Once an [eligible task runner](/workflows/concepts/task-runners#task-selection)
 from tilebox.workflows import Client
 
 client = Client()
-runner = client.runner("dev-cluster", tasks=[MyCronTask])
-runner.run_forever()
+runner = client.runner(tasks=[MyCronTask])
+runner.run_all()
 ```
 
 If this task runner runs continuously, its output may resemble the following:
@@ -128,16 +127,15 @@ job_client = client.jobs()
 task = MyCronTask(message="Hello")
 
 # submitting it directly won't work: raises ValueError:
-# CronTask cannot be submitted without being triggered. Use task.once().
-job_client.submit("manual-cron-job", task, cluster="dev-cluster")
-
-# specify a trigger time to submit the task as a regular task
-triggered_task = task.once()  # same as task.once(datetime.now())
-job_client.submit("manual-cron-job", triggered_task, cluster="dev-cluster")
-
-# simulate a trigger at a specific time
-triggered_task = task.once(datetime(2030, 12, 12, 15, 15, tzinfo=timezone.utc))
-# the task will be scheduled to run immediately, even with a future trigger time
-# but the self.trigger.time will be 2023-12-12T15:15:00Z for the task instance
-job_client.submit("manual-cron-job", triggered_task, cluster="dev-cluster")
+# job_client.submit("manual-cron-job", task)
+
+# instead trigger a cron task with the current time as the trigger time
+job_client.submit("manual-cron-job", task.once())
+
+# or specify a trigger time in the past or future
+# irrespective of the trigger time, the task will always be scheduled to run immediately
+job_client.submit(
+    "manual-cron-job", 
+    task.once(datetime(2030, 12, 12, 15, 15, tzinfo=timezone.utc))
+)
 ```
diff --git a/workflows/near-real-time/storage-events.mdx b/workflows/near-real-time/storage-events.mdx
index 5447bfc..535871d 100644
--- a/workflows/near-real-time/storage-events.mdx
+++ b/workflows/near-real-time/storage-events.mdx
@@ -120,7 +120,6 @@ client = Client()
 automations = client.automations()
 storage_event_automation = automations.create_storage_event_automation(
     "log-object-creations",  # name of the storage event automation
-    "dev-cluster",  # cluster slug to submit jobs to
     LogObjectCreation(head_bytes=20),  # the task (and its input parameters) to run repeatedly
     triggers=[
         # you can specify a glob pattern:
@@ -155,7 +154,7 @@ Once an [eligible task runner](/workflows/concepts/task-runners#task-selection)
 from tilebox.workflows import Client
 
 client = Client()
-runner = client.runner("dev-cluster", tasks=[LogObjectCreation])
+runner = client.runner(tasks=[LogObjectCreation])
 runner.run_forever()
 ```
 
@@ -212,19 +211,12 @@ job_client = client.jobs()
 task = LogObjectCreation(head_bytes=20)
 
 # submitting it directly won't work; raises ValueError:
-# StorageEventTask cannot be submitted without being triggered. Use task.once().
-job_client.submit(
-    "manual-storage-event-job",
-    task,
-    cluster="dev-cluster"
-)
+# job_client.submit("manual-storage-event-job", task)
 
-# instead, specify a trigger,
-# so that we can submit the task as a regular task
-triggered_task = task.once(gcs_bucket, "my-object.txt")
+# instead, we specify a trigger condition, and submit a job manually
 job_client.submit(
     "manual-storage-event-job",
-    triggered_task,
-    cluster="dev-cluster"
+    # simulate an event that occurred in the gcs bucket for the object "my-object.txt"
+    task.once(gcs_bucket, "my-object.txt"),
 )
 ```