Code generating process for generating stream processing code

A system comprising:

• a computer processor;
• a data repository in communication with the computer processor, wherein the data repository is configured to store:
• a user input,
• a user intent,
• a stream processing code,
• a test file, and
• a validation report;
• a supervising agent, when executed by the computer processor for a first time:
• receives the user input,
• extracts the user intent to generate the stream processing code from the user input, and
• routes the user input to a code-generating workflow based on the user intent;
• an extraction agent, when triggered by the code-generating workflow and executed by the computer processor:
• receives the user input;
• extracts stream processing information from a database based on the user input;
• and
• generates a structured data model based on the stream processing information;
• a code generating agent, when triggered by the code-generating workflow and executed by the computer processor:
• receives the structured data model;
• retrieves an example stream processing code from the database based on the structured data model;
• receives an input schema and an output schema from a tool;
• constructs a prompt for a code generation engine based on the structured data model, the input schema, the output schema, and the example stream processing code;
• inputs the prompt to the code generation engine;
• and
• receives the stream processing code and the test file from the code generation engine;
• a validation agent, when executed by the computer processor:
• receives the stream processing code and the test file from the code-generating workflow,
• validates the stream processing code using the test file, and
• generates the validation report indicating whether the stream processing code is validated;
• and
• the supervising agent, when executed by the computer processor for a second time:
• receives the validation report, and
• transmits the stream processing code to a user responsive to the validation report indicating that the stream processing code is validated.

A method comprising:

• receiving, by a supervising agent, a user input;
• extracting, by the supervising agent, at least a user intent to generate a stream processing code;
• routing, by the supervising agent, the user input to a code-generating workflow based on the user intent, the code-generating workflow comprising:
• receiving, by an extraction agent, the user input,
• extracting, by the extraction agent, stream processing information from a database based on the user input,
• generating, by the extraction agent, a structured data model based on stream processing information,
• receiving, by a code-generation agent, the structured data model,
• retrieving, by the code-generation agent, context from the database based on the structured data model,
• receiving, by the code-generation agent, an input schema and an output schema from a tool,
• constructing, by the code-generation agent, a prompt for a code generation engine based on the structured data model, the input schema, the output schema, and the context,
• inputting, by the code-generation agent, the prompt to the code generation engine, and
• receiving, by the code-generation agent, the stream processing code and at least one test file from the code generation engine;
• receiving, by a validation agent, the stream processing code and the at least one test file generated by the code-generating workflow;
• validating, by the validation agent, the stream processing code using the at least one test file;
• generating, by the validation agent, a validation report indicating whether the stream processing code is validated or is flagged;
• receiving, by the supervising agent, the validation report;
• and
• transmitting, by the supervising agent, the stream processing code to a user when the validation report indicates that the stream processing code is validated or triggering, by the supervising agent, a revision process when the validation report flags the stream processing code.