How do i emit a success event to the monitor?

[azambuilds]

I have a worker like this:

Monitor::new()
    // .register(cron_producer_worker)
    .register(worker_1)
    .on_event(|event| {
        let worker_id = event.id();

        match event.inner() {
            Event::Start => {
                tracing::info!("Worker {} started", worker_id);
            }
            Event::Error(err) => {
                tracing::error!("Worker {} errored: {:?}", worker_id, err);
            }
            Event::Exit => {
                tracing::info!("Worker {} exited", worker_id);
            }
            _ => {
                tracing::info!("Worker {} Uhandled event: {:?}", worker_id, event);
            }
        }
    })
    .run()
    .await
    .unwrap();

I notice that if I emit an abort/failure error in the worker function, Event::Error is emitted. I also notice Event::Start is emitted when the worker starts.

But I notice that if I return Ok(()), no event is emitted to the monitor:

    let worker_1 = WorkerBuilder::new("worker-1")
        .enable_tracing()
        .catch_panic()
        .layer(ErrorHandlingLayer::new())
        .rate_limit(2, Duration::from_secs(60))
        .backend(storage)
        .build_fn(move |job| {
            async move { Ok::<(), apalis::prelude::Error>(()) }
        });

I don't actually see any event emitted at the end, it just ends. Is this right? Please let me know if there's a way to explicitely emit a "success" event or something like that

Also I want to be able to track the "status" of a worker, like is it running, it is started/in queue, is it ended, etc. Or is that something handled elsewhere? Maybe there's an example which I haven't seen yet that covers this?

[geofmureithi]

Currently workers dont emit success events. I can consider adding success events.

Also I want to be able to track the "status" of a worker, like is it running, it is started/in queue, is it ended, etc. Or is that something handled elsewhere? Maybe there's an example which I haven't seen yet that covers this?

Regarding this You can either:

• use Runnable::get_handle()
• Get Worker<Context> in the execution fn and check these properties. See https://github.com/geofmureithi/apalis/blob/main/examples/unmonitored-worker/src/main.rs