Operational Implementation

@tool(name="OpsImplementationPlanner", description="Generate operational workflows for underwriting, policy administration, and distribution channels.", show_result=True)
def OpsImplementationPlanner(
    product_blueprint_csv: str = None,
    operational_guidelines_csv: str = None,
) -> str:
    """
    Generate operational workflows for underwriting, policy administration, and distribution channels.

    Args:
        product_blueprint_csv: Path to CSV with product blueprint specifications.
        operational_guidelines_csv: CSV with operational guidelines and best practices.

    Returns:
        str: JSON string with suggested workflows for each product.
    """
    product_blueprint_csv = product_blueprint_csv or _path("agent2.csv")
    operational_guidelines_csv = operational_guidelines_csv or _path("agent2.csv")
    try:
        blueprints = pd.read_csv(product_blueprint_csv)
        guidelines = pd.read_csv(operational_guidelines_csv)
        workflows = []
        for _, product in blueprints.iterrows():
            uw = "Standard financial/medical underwriting"
            pa = "Standard long-term policy admin"
            dist = "Bancassurance / brokers / corporate partnerships"
            if "Underwriting" in guidelines.columns and len(guidelines) > 0:
                uw = str(guidelines["Underwriting"].iloc[0])
            if "PolicyAdmin" in guidelines.columns and len(guidelines) > 0:
                pa = str(guidelines["PolicyAdmin"].iloc[0])
            if "Distribution" in guidelines.columns and len(guidelines) > 0:
                dist = str(guidelines["Distribution"].iloc[0])
            workflow = {
                "ProductID": product["ProductID"] if "ProductID" in product.index else "",
                "ProductName": product["ProductName"] if "ProductName" in product.index else "",
                "UnderwritingWorkflow": uw,
                "PolicyAdministrationWorkflow": pa,
                "DistributionWorkflow": dist,
            }
            workflows.append(workflow)
        return json.dumps(workflows, indent=2)
    except Exception as e:
        return json.dumps({"error": str(e)})