Skip to content

Commit 5745bb4

Browse files
committed
Adds registration log lines
Signed-off-by: joshvanl <[email protected]>
1 parent 6283dd9 commit 5745bb4

File tree

2 files changed

+20
-1
lines changed

2 files changed

+20
-1
lines changed

tests/apps/scheduler/app.go

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,8 @@ func register(ctx context.Context) {
7979
log.Fatal(err)
8080
}
8181

82+
log.Printf("Scheduled job test1")
83+
8284
if err = cl.ScheduleJobAlpha1(ctx, &client.Job{
8385
Name: "test2",
8486
Schedule: ptr.Of("@every 100m"),
@@ -90,6 +92,8 @@ func register(ctx context.Context) {
9092
log.Fatal(err)
9193
}
9294

95+
log.Printf("Scheduled job test2")
96+
9397
if err = cl.RegisterActorReminder(ctx, &client.RegisterActorReminderRequest{
9498
ActorType: "myactortype",
9599
ActorID: "actorid1",
@@ -100,6 +104,8 @@ func register(ctx context.Context) {
100104
log.Fatal(err)
101105
}
102106

107+
log.Printf("Scheduled actor reminder test1")
108+
103109
if err = cl.RegisterActorReminder(ctx, &client.RegisterActorReminderRequest{
104110
ActorType: "myactortype",
105111
ActorID: "actorid2",
@@ -110,6 +116,8 @@ func register(ctx context.Context) {
110116
log.Fatal(err)
111117
}
112118

119+
log.Printf("Scheduled actor reminder test2")
120+
113121
r := workflow.NewRegistry()
114122

115123
if err := r.AddWorkflow(W1); err != nil {
@@ -134,15 +142,26 @@ func register(ctx context.Context) {
134142
if _, err = wf.ScheduleWorkflow(ctx, "W1", workflow.WithInstanceID("abc1")); err != nil {
135143
log.Fatal(err)
136144
}
145+
146+
log.Printf("Scheduled workflow W1 with id abc1")
147+
137148
if _, err = wf.ScheduleWorkflow(ctx, "W1", workflow.WithInstanceID("abc2")); err != nil {
138149
log.Fatal(err)
139150
}
151+
152+
log.Printf("Scheduled workflow W1 with id abc2")
153+
140154
if _, err = wf.ScheduleWorkflow(ctx, "W2", workflow.WithInstanceID("xyz1")); err != nil {
141155
log.Fatal(err)
142156
}
157+
158+
log.Printf("Scheduled workflow W2 with id xyz1")
159+
143160
if _, err = wf.ScheduleWorkflow(ctx, "W2", workflow.WithInstanceID("xyz2")); err != nil {
144161
log.Fatal(err)
145162
}
163+
164+
log.Printf("Scheduled workflow W2 with id xyz2")
146165
}
147166

148167
// StartServer starts a HTTP or HTTP2 server

tests/e2e/standalone/scheduler_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ func TestSchedulerList(t *testing.T) {
5959
output, err := cmdSchedulerList()
6060
require.NoError(t, err)
6161
assert.Len(c, strings.Split(output, "\n"), 10)
62-
}, time.Second*180, time.Millisecond*10)
62+
}, time.Second*30, time.Millisecond*10)
6363

6464
t.Run("short", func(t *testing.T) {
6565
output, err := cmdSchedulerList()

0 commit comments

Comments
 (0)