def METHOD_NAME(
    self,
    mcg_job_factory,
    resource_to_delete,
    worker_node,
):
    """
    Generate S3 workload to trigger autoscale to increase from 1 to 2 endpoint
    then respin ceph pods
    """
    # Add workers node to cluster
    scale_pgsql.add_worker_node()
    # Check autoscale endpoint count before start s3 load
    self._assert_endpoint_count(desired_count=self.MIN_ENDPOINT_COUNT)
    endpoint_cnt = get_endpoint_pod_count(config.ENV_DATA["cluster_namespace"])
    get_hpa_utilization(config.ENV_DATA["cluster_namespace"])
    job_cnt = 0
    wait_time = 30
    job_list = list()
    while endpoint_cnt < self.MAX_ENDPOINT_COUNT:
        exec(f"job{job_cnt} = mcg_job_factory(custom_options=options)")
        job_list.append(f"job{job_cnt}")
        time.sleep(wait_time)
        endpoint_cnt = get_endpoint_pod_count(config.ENV_DATA["cluster_namespace"])
        hpa_cpu_utilization = get_hpa_utilization(
            config.ENV_DATA["cluster_namespace"]
        )
        log.info(
            f"HPA CPU utilization by noobaa-endpoint is {hpa_cpu_utilization}%"
        )
        if endpoint_cnt == self.MAX_ENDPOINT_COUNT:
            break
        job_cnt += 1
    # Validate autoscale endpoint count
    self._assert_endpoint_count(desired_count=self.MAX_ENDPOINT_COUNT)
    # Respin ceph pods
    disruption = disruption_helpers.Disruptions()
    disruption.set_resource(resource=resource_to_delete)
    number_of_resource = disruption.resource_count
    for i in range(0, number_of_resource):
        disruption.delete_resource(resource_id=i)
    # Delete mcg_job_factory
    for job in job_list:
        exec(f"{job}.delete()")
        exec(f"{job}.ocp.wait_for_delete(resource_name={job}.name, timeout=60)")
    # Validate autoscale endpoint count
    self._assert_endpoint_count(desired_count=self.MIN_ENDPOINT_COUNT)
    # Check ceph health status
    utils.ceph_health_check()