[Feature] Add support for custom job name in Flink Agents Job execution #560
Description
Search before asking
- I searched in the issues and found nothing similar.
Description
When submitting a Flink Agents Job to a Flink cluster following the quickstart guide, the job appears in the Flink Web UI with the default name "Flink Streaming Job". This makes it difficult to identify and manage multiple agent jobs running in the cluster.
Proposed Solution
Add a job_name parameter to the execute() method to allow users to specify a custom job name programmatically.
Current Implementation:
def execute(self) -> None:
"""Execute agent individually."""Proposed Implementation:
def execute(self, job_name: str = None) -> None:
"""Execute agent individually.
Args:
job_name: Optional custom name for the Flink job.
"""Use Case Example
agent_env.execute(job_name="Diagnosis Agent")Are you willing to submit a PR?
- I'm willing to submit a PR!