fix exceptions

microsoft · Nov 15, 2024 · 42ccad3 · 42ccad3
1 parent 89ffbca
commit 42ccad3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcGateway.cs b/dotnet/src/Microsoft.AutoGen/Agents/Services/Grpc/GrpcGateway.cs
@@ -118,7 +118,7 @@ private async ValueTask AddSubscriptionAsync(GrpcWorkerConnection connection, Ad
         var topic = request.Subscription.TypeSubscription.TopicType;
         var agentType = request.Subscription.TypeSubscription.AgentType;
         _subscriptionsByAgentType[agentType] = request.Subscription;
-        _subscriptionsByTopic[topic].Add(agentType);
+        _subscriptionsByTopic.GetOrAdd(topic, _ => []).Add(agentType);
         await _subscriptions.Subscribe(topic, agentType);
         //var response = new AddSubscriptionResponse { RequestId = request.RequestId, Error = "", Success = true };
         Message response = new()

diff --git a/python/packages/autogen-core/samples/xlang/worker.py b/python/packages/autogen-core/samples/xlang/worker.py
@@ -33,7 +33,7 @@ async def main() -> None:
     await runtime.add_subscription(DefaultSubscription(agent_type="proxy"))
     agnext_logger.info("3")
 
-    await runtime.publish_message(message=Input(message=""), topic_id="HelloAgents")
+    await runtime.publish_message(message=Input(message=""), topic_id=DefaultTopicId())
     await runtime.stop_when_signal()
     # await runtime.stop_when_idle()