Has anyone had any success on running a channel listener in a kernel. eg
- Create Channel (CreateChannel["test" ])
- Spin up kernel to process resuls
- Send channel message from another process.
I can not get the channel listener active in this scenario. When I run it from the front end it works but in the kernel it does not. Any suggestions would be appreciated:
list = {1, 2};
ParallelMap[{Print["Processing job: ", #];
listener = ChannelListen["test", myfunc];
Print["listener: ", listener, " kern ", $KernelID, " job ", #];
Pause[60]} &, list]
myfunc[a_Association] :=
Module[{},
Print["printed from my func", a , " in kern: ", $KernelID] ];
IN ANOTHER SESSION: ChannelSend["test", <|"a" -> "hello", "msg" -> RandomReal[]|>]