def METHOD_NAME(ceph_cluster: Ceph, **kwargs) -> int:
    """
    Entry point to this module that executes the set of workflows.
    Here, Cloud Object Store Benchmark tool (WARP) is pushing workload to its client
    Args:
        ceph_cluster:   Cluster participating in the test.
    Returns:
        0 on Success and 1 on Failure.
    """
    LOG.info("Push workload to warp.")
    client = ceph_cluster.get_nodes(role="installer")[0]
    warp_server = get_nodes_by_ids(ceph_cluster, kwargs["config"]["warp_server"])
    warp_clients = get_nodes_by_ids(ceph_cluster, kwargs["config"]["warp_client"])
    ha_clients = get_nodes_by_ids(ceph_cluster, kwargs["config"]["haproxy_client"])
    run_duration = kwargs["config"].get("duration", "1m")
    warp_operation = kwargs["config"].get("operation", "put")
    bucket_count = kwargs["config"].get("bucket_count", 6)
    try:
        bucket_count = kwargs["config"].get("bucket_count", 6)
        push_io(
            warp_server,
            warp_clients,
            ha_clients,
            client,
            bucket_count,
            run_duration,
            warp_operation,
        )
    except BaseException as be:  # noqa
        LOG.error(be)
        return 1
    LOG.info("Workload initited successfully!!!")
    return 0