Method Run

tests/integration/suite/scheduler/metrics/jobsfailedtotal.go:59–98

(t *testing.T, ctx context.Context)

}

func (j *jobsfailedtotal) Run(t *testing.T, ctx context.Context) {
	j.actors.WaitUntilRunning(t, ctx)

	client := j.actors.GRPCClient(t, ctx)

	for i := range 5 {
		_, err := client.ScheduleJob(ctx, &rtv1.ScheduleJobRequest{
			Job: &rtv1.Job{
				Name:    strconv.Itoa(i),
				DueTime: new("0s"),
				FailurePolicy: &common.JobFailurePolicy{
					Policy: &common.JobFailurePolicy_Drop{
						Drop: new(common.JobFailurePolicyDrop),
					},
				},
			},
		})
		require.NoError(t, err)
	}

	for i := range 3 {
		_, err := client.RegisterActorReminder(ctx, &rtv1.RegisterActorReminderRequest{
			ActorType: "my-type",
			ActorId:   strconv.Itoa(i),
			Name:      strconv.Itoa(i),
			DueTime:   "0s",
		})
		require.NoError(t, err)
	}

	assert.EventuallyWithT(t, func(c *assert.CollectT) {
		metrics := j.actors.Scheduler().MetricsWithLabels(t, ctx)
		total, ok := metrics.Metrics["dapr_scheduler_jobs_failed_total"]
		if !assert.True(c, ok) {
			return
		}
		assert.InDelta(c, 5.0, total["type=job"], 0.01)
		assert.InDelta(c, 9.0, total["type=actor"], 0.01)
	}, time.Second*15, time.Millisecond*10)
}