Compare commits

..

No commits in common. "master" and "v1.1.0" have entirely different histories.

4 changed files with 10 additions and 14 deletions

View File

@ -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

View File

@ -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
}
```

View File

@ -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()

View File

@ -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()
}