Install Flink agents for the default Python.

Author: GreatEugenius

.github/workflows/ci.yml

@@ -144,7 +144,10 @@ jobs:
         with:
           version: "latest"
       - name: Install flink-agents
-        run: bash tools/build.sh
+        run: |
+          bash tools/build.sh
+          cd python
+          pip install dist/*.whl
       - name: Install ollama
         run: bash tools/start_ollama_server.sh
       - name: Run Java IT

api/src/main/java/org/apache/flink/agents/api/chat/messages/ChatMessage.java

@@ -32,9 +32,6 @@
  */
 public class ChatMessage {
 
-    /** The key for the message type in the metadata. */
-    public static final String MESSAGE_TYPE = "messageType";
-
     private MessageRole role;
     private String content;
     private List<Map<String, Object>> toolCalls;
@@ -68,7 +65,6 @@ public ChatMessage(
         this.content = content != null ? content : "";
         this.toolCalls = toolCalls != null ? toolCalls : new ArrayList<>();
         this.extraArgs = extraArgs != null ? new HashMap<>(extraArgs) : new HashMap<>();
-        this.extraArgs.put(MESSAGE_TYPE, this.role);
     }
 
     public MessageRole getRole() {
@@ -77,7 +73,6 @@ public MessageRole getRole() {
 
     public void setRole(MessageRole role) {
         this.role = role;
-        this.extraArgs.put(MESSAGE_TYPE, this.role);
     }
 
     public String getContent() {
@@ -102,7 +97,6 @@ public Map<String, Object> getExtraArgs() {
 
     public void setExtraArgs(Map<String, Object> extraArgs) {
         this.extraArgs = extraArgs != null ? extraArgs : new HashMap<>();
-        this.extraArgs.put(MESSAGE_TYPE, this.role);
     }
 
     @JsonIgnore