Compare commits
No commits in common. "master" and "v1.1.0" have entirely different histories.
@ -39,7 +39,7 @@ jobs:
|
||||
run: |
|
||||
curl -X POST \
|
||||
-H "Content-Type: text/plain" \
|
||||
-d "✅ <b>task</b> success! View run at: https://git.canoozie.net/${{ gitea.repository }}/actions/runs/${{ gitea.run_number }}" \
|
||||
-d "✅ `task` success! View run at: https://git.canoozie.net/${{ gitea.repository }}/actions/runs/${{ gitea.run_number }}" \
|
||||
https://chat.canoozie.net/rooms/5/2-q6gKxqrTAfhd/messages
|
||||
|
||||
- name: Send failure notification
|
||||
@ -47,5 +47,5 @@ jobs:
|
||||
run: |
|
||||
curl -X POST \
|
||||
-H "Content-Type: text/plain" \
|
||||
-d "❌ <b>task</b> failure! View run at: https://git.canoozie.net/${{ gitea.repository }}/actions/runs/${{ gitea.run_number }}" \
|
||||
-d "❌ `task` failure! View run at: https://git.canoozie.net/${{ gitea.repository }}/actions/runs/${{ gitea.run_number }}" \
|
||||
https://chat.canoozie.net/rooms/5/2-q6gKxqrTAfhd/messages
|
||||
|
@ -28,7 +28,6 @@ go get git.canoozie.net/jer/task
|
||||
package main
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"time"
|
||||
|
||||
@ -46,7 +45,7 @@ func (t *MyTask) ID() string {
|
||||
return t.TaskID
|
||||
}
|
||||
|
||||
func (t *MyTask) Execute(ctx context.Context) error {
|
||||
func (t *MyTask) Execute() error {
|
||||
fmt.Printf("Executing task: %s\n", t.Name)
|
||||
return nil
|
||||
}
|
||||
@ -136,13 +135,13 @@ To create a task, implement the `Task` interface:
|
||||
```go
|
||||
type Task interface {
|
||||
ID() string
|
||||
Execute(ctx context.Context) error
|
||||
Execute() error
|
||||
Dependencies() []string
|
||||
}
|
||||
```
|
||||
|
||||
- `ID()` - Returns a unique identifier for this task
|
||||
- `Execute(ctx context.Context)` - Performs the task's operation with context, returning any errors
|
||||
- `Execute()` - Performs the task's operation, returning any errors
|
||||
- `Dependencies()` - Returns a list of task IDs that must complete successfully before this task can run
|
||||
|
||||
Any errors returned from `Execute()` will be logged and will prevent dependent tasks from running.
|
||||
@ -155,7 +154,7 @@ Any errors returned from `Execute()` will be logged and will prevent dependent t
|
||||
```go
|
||||
type Task interface {
|
||||
ID() string
|
||||
Execute(ctx context.Context) error
|
||||
Execute() error
|
||||
Dependencies() []string
|
||||
}
|
||||
```
|
||||
|
8
task.go
8
task.go
@ -1,7 +1,6 @@
|
||||
package task
|
||||
|
||||
import (
|
||||
"context"
|
||||
"log"
|
||||
"sync"
|
||||
"time"
|
||||
@ -9,7 +8,7 @@ import (
|
||||
|
||||
type Task interface {
|
||||
ID() string
|
||||
Execute(ctx context.Context) error
|
||||
Execute() error
|
||||
Dependencies() []string
|
||||
}
|
||||
|
||||
@ -347,9 +346,8 @@ func (te *TaskExecutor) executeTask(st *ScheduledTask) {
|
||||
}
|
||||
te.completedTasksMutex.Unlock()
|
||||
|
||||
// Execute the task with a background context
|
||||
ctx := context.Background()
|
||||
err := st.task.Execute(ctx)
|
||||
// Execute the task
|
||||
err := st.task.Execute()
|
||||
|
||||
// Update final task status
|
||||
te.completedTasksMutex.Lock()
|
||||
|
@ -1,7 +1,6 @@
|
||||
package task
|
||||
|
||||
import (
|
||||
"context"
|
||||
"errors"
|
||||
"testing"
|
||||
"time"
|
||||
@ -17,7 +16,7 @@ func (m *mockTask) ID() string {
|
||||
return m.id
|
||||
}
|
||||
|
||||
func (m *mockTask) Execute(ctx context.Context) error {
|
||||
func (m *mockTask) Execute() error {
|
||||
return m.executeFunc()
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user