feat: add streaming chunk events

[JINO-ROHIT]

im unaware if this works correctly but figured it might be a good idea to get early feedback -

1. adds TaskStreamingChunkEvent
2. adds asbtract method in callback
3. extends workforce logger
4. update single_agent_worker to handle streaming chunks via this task

[coderabbitai]

Important

Review skipped

Auto reviews are disabled on this repository.

Please check the settings in the CodeRabbit UI or the .coderabbit.yaml file in this repository. To trigger a single review, invoke the @coderabbitai review command.

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

✨ Finishing touches

🧪 Generate unit tests (beta)

• Create PR with unit tests
• Post copyable unit tests in a comment
• Commit unit tests in branch feat-3379

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands and usage tips.}

[fengju0213]

@JINO-ROHIT thanks for contribution！

[fengju0213]

Thanks for working on this feature! The overall direction is correct, but there are some critical issues that need to be addressed before this can work properly.

[fengju0213]

here assumes self.callback exists in SingleAgentWorker, but it doesn't. Workers have no way to access the callbacks registered in Workforce.

[fengju0213]

maybe we need add a mechanism to propagate callbacks from Workforce to Worker instances.

[fengju0213]

For the worker callback, I suggest implementing callback support at the BaseNode level, since all node types (both Worker and Workforce) could benefit from this change.
However, it might be good to get some feedback from @Wendong-Fan on this idea.

[fengju0213]

log_task_streaming_chunk is defined as a synchronous method in WorkforceCallback

[JINO-ROHIT]

yeah thanks, i suppose we wait till wendong gives some comments then, ill also take some time to come up w alts,