How to access gocron.Job

[justpoypoy]

How to access job interfaces eg. job.LastRun(), job.ID() inside task

this my example code

	repo := repositories.New(r.di)
	services := usecases.New(repo)
	handle := handler.New(services)
_, err := s.NewJob(
		gocron.DailyJob(
			1,
			gocron.NewAtTimes(
				gocron.NewAtTime(17, 27, 30),
				gocron.NewAtTime(17, 27, 40),
				gocron.NewAtTime(17, 27, 50),
			),
		),
		gocron.NewTask(handle.GetDailyTransaction),
		gocron.WithSingletonMode(gocron.LimitModeWait),
	)

and how to access unique id or last run inside function GetDailyTransaction

[JohnRoesler]

hi @justpoypoy

Have you tried setting the job object no the call to NewJob and then referencing it?

	repo := repositories.New(r.di)
	services := usecases.New(repo)
	handle := handler.New(services)
	job, err := s.NewJob(
		gocron.DailyJob(
			1,
			gocron.NewAtTimes(
				gocron.NewAtTime(17, 27, 30),
				gocron.NewAtTime(17, 27, 40),
				gocron.NewAtTime(17, 27, 50),
			),
		),
		gocron.NewTask(handle.GetDailyTransaction(job.ID())),
		gocron.WithSingletonMode(gocron.LimitModeWait),
	)

[justpoypoy]

hi @JohnRoesler sure, have been tried but job object is return from NewJob right? so i get error undefined job

[JohnRoesler]

ah, yes right. Well, for the UUID, you can set your own, and then pass that variable in

https://pkg.go.dev/github.com/go-co-op/gocron/v2#WithIdentifier

[justpoypoy]

yes if i want parse the UUID, but i want get the instance of gocron.Job like the v1 i used before.

s := gocron.NewScheduler(time.Local)
s.Every(1).At("03:00").Day().Saturday().Sunday().Do(handle.GetTransactionsHandler)

s.StartBlocking()

and consumed by handler like this

func (h *handler) GetTransactionsHandler(job gocron.Job) error {
        fmt.Println(job.LastRun())
	return nil
}

[JohnRoesler]

@justpoypoy you CAN do something like this, but it's not really that helpful as last run is going to be the same as time.Now

package main

import (
	"log/slog"
	"time"

	"github.com/go-co-op/gocron/v2"
)

func main() {
	scheduler, err := gocron.NewScheduler()
	if err != nil {
		panic(err)
	}

	var job gocron.Job

	job, err = scheduler.NewJob(
		gocron.DurationJob(time.Second),
		gocron.NewTask(func() {
			lastRun, err := job.LastRun()
			if err != nil {
				slog.Error("job run", slog.String("error", err.Error()))
			} else {
				slog.Info("job run", slog.String("last_run", lastRun.String()))
			}
		}),
	)
	if err != nil {
		panic(err)
	}

	scheduler.Start()
	for {
	}
}

If I understand your request, you want to be able to take some action based on the last time the job ran inside of your task function? Could you help me understand the use case a little better?

[justpoypoy]

thanks for helping, my usecase is getting time of last running scheduler and use it for query to database