def METHOD_NAME(
    self, nodes, multiple_snapshot_and_clone_of_postgres_pvc_factory, sc_name=None
):
    log.info("Starting multiple creation & clone of postgres PVC in Background")
    bg_handler = flowtest.BackgroundOps()
    executor_run_bg_ops = ThreadPoolExecutor(max_workers=1)
    pgsql_snapshot_and_clone = executor_run_bg_ops.submit(
        bg_handler.handler,
        multiple_snapshot_and_clone_of_postgres_pvc_factory,
        pvc_size_new=25,
        pgsql=self.pgsql,
        sc_name=sc_name,
        iterations=1,
    )
    log.info("Started creation of snapshots & clones in background")
    flow_ops = flowtest.FlowOperations()
    log.info("Starting operation 1: Pod Restarts")
    disruption = Disruptions()
    pod_obj_list = [
        "osd",
        "mon",
        "mgr",
        "operator",
        "rbdplugin",
        "rbdplugin_provisioner",
    ]
    for pod in pod_obj_list:
        disruption.set_resource(resource=f"{pod}")
        disruption.delete_resource()
    log.info("Verifying exit criteria for operation 1: Pod Restarts")
    flow_ops.validate_cluster(
        node_status=True, pod_status=True, operation_name="Pod Restarts"
    )
    log.info("Starting operation 2: Node Reboot")
    node_names = flow_ops.node_operations_entry_criteria(
        node_type="worker", number_of_nodes=3, operation_name="Node Reboot"
    )
    # Reboot node
    nodes.restart_nodes(node_names)
    log.info("Verifying exit criteria for operation 2: Node Reboot")
    flow_ops.validate_cluster(
        node_status=True, pod_status=True, operation_name="Node Reboot"
    )
    log.info("Starting operation 3: Node Drain")
    node_name = flow_ops.node_operations_entry_criteria(
        node_type="worker", number_of_nodes=1, operation_name="Node Drain"
    )
    # Node maintenance - to gracefully terminate all pods on the node
    drain_nodes([node_name[0].name])
    # Make the node schedulable again
    schedule_nodes([node_name[0].name])
    log.info("Verifying exit criteria for operation 3: Node Drain")
    flow_ops.validate_cluster(
        node_status=True, pod_status=True, operation_name="Node Drain"
    )
    log.info("Waiting for background operations to be completed")
    bg_handler.wait_for_bg_operations([pgsql_snapshot_and_clone], timeout=600)