Merge pull request #628 from tnfssc/fix/streaming-not-working

This commit is contained in:
Sharath 2025-06-05 07:31:07 +05:30 committed by GitHub
commit 9761df816a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions

View File

@ -135,8 +135,8 @@ async def run_agent_background(
# Store response in Redis list and publish notification
response_json = json.dumps(response)
pending_redis_operations.append(redis.rpush(response_list_key, response_json))
pending_redis_operations.append(redis.publish(response_channel, "new"))
pending_redis_operations.append(asyncio.create_task(redis.rpush(response_list_key, response_json)))
pending_redis_operations.append(asyncio.create_task(redis.publish(response_channel, "new")))
total_responses += 1
# Check for agent-signaled completion or error