@@ -15,7 +15,7 @@ Organize related tasks to create complex workflows:
15
15
// src/app/tasks/data-processing.ts
16
16
import { task } from ' @commandkit/tasks' ;
17
17
18
- export const dataProcessing = task ({
18
+ export default task ({
19
19
name: ' data-processing' ,
20
20
schedule: ' 0 2 * * *' , // Daily at 2 AM
21
21
async execute(ctx ) {
@@ -43,7 +43,7 @@ Implement custom retry logic for failed tasks:
43
43
// src/app/tasks/retry-example.ts
44
44
import { task } from ' @commandkit/tasks' ;
45
45
46
- export const retryTask = task ({
46
+ export default task ({
47
47
name: ' retry-task' ,
48
48
async execute(ctx ) {
49
49
const { attempt = 1 , maxAttempts = 3 } = ctx .data ;
@@ -87,7 +87,7 @@ Manage tasks that depend on other conditions:
87
87
// src/app/tasks/dependency-example.ts
88
88
import { task } from ' @commandkit/tasks' ;
89
89
90
- export const dependencyTask = task ({
90
+ export default task ({
91
91
name: ' dependency-task' ,
92
92
async execute(ctx ) {
93
93
const { requiredData } = ctx .data ;
@@ -114,7 +114,7 @@ Process multiple items in batches:
114
114
// src/app/tasks/batch-processing.ts
115
115
import { task } from ' @commandkit/tasks' ;
116
116
117
- export const batchProcessor = task ({
117
+ export default task ({
118
118
name: ' batch-processor' ,
119
119
schedule: ' 0 */6 * * *' , // Every 6 hours
120
120
async execute(ctx ) {
@@ -156,7 +156,7 @@ Track task execution metrics:
156
156
// src/app/tasks/metrics.ts
157
157
import { task } from ' @commandkit/tasks' ;
158
158
159
- export const metricsTask = task ({
159
+ export default task ({
160
160
name: ' metrics-task' ,
161
161
schedule: ' 0 * * * *' , // Every hour
162
162
async execute(ctx ) {
@@ -197,7 +197,7 @@ Use the context store to manage state across task executions:
197
197
// src/app/tasks/state-management.ts
198
198
import { task } from ' @commandkit/tasks' ;
199
199
200
- export const statefulTask = task ({
200
+ export default task ({
201
201
name: ' stateful-task' ,
202
202
schedule: ' 0 */2 * * *' , // Every 2 hours
203
203
async prepare(ctx ) {
@@ -235,7 +235,7 @@ Implement cleanup tasks for resource management:
235
235
// src/app/tasks/cleanup.ts
236
236
import { task } from ' @commandkit/tasks' ;
237
237
238
- export const cleanupTask = task ({
238
+ export default task ({
239
239
name: ' cleanup' ,
240
240
schedule: ' 0 3 * * *' , // Daily at 3 AM
241
241
async execute(ctx ) {
@@ -263,7 +263,7 @@ Implement robust error recovery mechanisms:
263
263
// src/app/tasks/error-recovery.ts
264
264
import { task } from ' @commandkit/tasks' ;
265
265
266
- export const resilientTask = task ({
266
+ export default task ({
267
267
name: ' resilient-task' ,
268
268
async execute(ctx ) {
269
269
const { operation, fallbackOperation } = ctx .data ;
@@ -303,7 +303,7 @@ export const resilientTask = task({
303
303
// src/app/tasks/rolling-window.ts
304
304
import { task } from ' @commandkit/tasks' ;
305
305
306
- export const rollingWindowTask = task ({
306
+ export default task ({
307
307
name: ' rolling-window' ,
308
308
schedule: ' */15 * * * *' , // Every 15 minutes
309
309
async execute(ctx ) {
@@ -325,7 +325,7 @@ export const rollingWindowTask = task({
325
325
// src/app/tasks/adaptive-processing.ts
326
326
import { task } from ' @commandkit/tasks' ;
327
327
328
- export const adaptiveTask = task ({
328
+ export default task ({
329
329
name: ' adaptive-task' ,
330
330
schedule: ' */5 * * * *' , // Every 5 minutes
331
331
async execute(ctx ) {
0 commit comments