5 Commits

Author	SHA1	Message	Date
Marvin Zhang	61604e1817	fix(task/handler): ensure latest gRPC client is used for task fetch/subscribe ... Add svc.getGrpcClient() helper and use it when obtaining TaskClient so task fetch and subscribe operations don't hold a stale client instance after ResetGrpcClient().	2025-10-20 12:22:34 +08:00
Marvin Zhang	afa5fab4c1	feat: enhance task reconciliation with worker-side status caching and synchronization	2025-09-17 11:03:35 +08:00
Marvin Zhang	6912b92501	refactor: enhance context handling across task runner and service components; ensure proper cancellation chains and prevent goroutine leaks	2025-08-07 15:40:48 +08:00
Marvin Zhang	44dd68918f	refactor: improve goroutine management and context handling in task and stream operations; ensure graceful shutdown and prevent leaks	2025-08-07 00:16:46 +08:00
Marvin Zhang	784ffc8b52	feat: implement task management service operations, stream manager, and worker pool ... - Added service_operations.go for task management including run, cancel, and execution logic. - Introduced stream_manager.go to handle task streams and manage cancellation signals. - Created worker_pool.go to manage a bounded pool of workers for executing tasks concurrently. - Implemented graceful shutdown and cleanup mechanisms for task runners and streams. - Enhanced error handling and logging throughout the task management process.	2025-08-06 18:29:08 +08:00