Hi. My application uses Horde.DynamicSupervisor to spawn processing tasks for unique objects. User should be able to abort the task, and for that purpose I am trying to lookup the task in Horde.Registry to then use Horde.DynamicSupervisor.terminate_child(pid). However the Registry seems to be unawar…

[image] 1stSolo: So here’s what works: Added atom to child_spec when starting the Task under Horde’s Dynamic Supervisor: {:ok, _pid} = Horde.DynamicSupervisor.start_child( DataImportSupervisor, %{ id: {:process_data_import, di.id}, start: {Task, :start_link, [DataImportWorker, :process_da…

[image] 1stSolo: Why is Horde’s DynamicSupervisor not registering the Task in the Registry? This doesn’t happen automatically - how could it? DataImportSupervisor doesn’t take any configuration about what registry to use. The standard approach is to pass a name: with a via tuple when startin…

I haven’t tried register from DataImportWorker yet, but I have tried to register() task’s pid from the main thread after {:ok, pid} = Horde.DynamicSupervisor.start_child( DataImportSupervisor, %{ id: my_data_object.uuid, start: {Task, :start_link, [DataI…

I did this: {:ok, pid} = Horde.DynamicSupervisor.start_child( DataImportSupervisor, %{ id: {:via, Horde.Registry, {DataImportRegistry, my_object.uuid}}, start: {Task, :start_link, [DataImportWorker, :process_data_import, [my_object]]} })…

It’s a bit confusing, but it’s the Task name you need to be setting using the via tuple, not the child spec id. The id is a value used by the supervisor to determine uniqueness, but it doesn’t name the process. Take a look at this example for the built-in Registry: Registry — Elixir v1.12.3 You al…

[image] 1stSolo: then if I have to manually register the process how does it get unregistered? The registry adds a monitor for the process that calls register, so that when that process exits the registry is notified and can un-register the name. This article walks through a detailed example…

I’m afraid I’m still confused. I don’t see an API to start a Task with a via tuple. There’s one in Agent or GenServer but I could not find one in Task. Maybe my whole approach is wrong. I don’t care about the state. I have an API that needs to kick off asynchronous processing of an object/piece of …

[image] 1stSolo: There’s one in Agent or GenServer but I could not find one in Task. Tasks don’t have a built-in API to register with names because Tasks don’t usually process unsolicited messages from other processes (unlike GenServer, for instance); you’d need to explicitly call receive ins…

Thanks, all, I’m making some good progress. I read somewhere that Horde.Registry.register needs to be called from within the Task to work properly. It appears to be so. When I was trying to register the Task in the registry from the main (caller) process it wasn’t getting registered. Also, the 3rd a…

Elixir Programming Language Forum

Horde.DynamicSupervisor bypasses Registry?

Questions & Help Questions

1stSolo August 16, 2022, 12:23am 11

Thanks, all, for your help!