def METHOD_NAME(client, queue, job_set_id, job_request_items):
    """
    Example workflow for the async logging example
    """
    queue_req = client.create_queue_request(name=queue, priority_factor=1)
    # Handle if the queue already exists
    try:
        client.create_queue(queue_req)
    # Handle the error we expect to maybe occur
    except grpc.RpcError as e:
        code = e.code()
        if code == grpc.StatusCode.ALREADY_EXISTS:
            print(f"Queue {queue} already exists")
            queue_req = client.create_queue_request(name=queue, priority_factor=1)
            client.update_queue(queue_req)
        else:
            raise e
    # Some different commands for logging to detect
    queue_req = client.create_queue_request(name=queue, priority_factor=2)
    client.update_queue(queue_req)
    resp = client.submit_jobs(
        queue=queue, job_set_id=job_set_id, job_request_items=job_request_items
    )
    # Cancel the job
    job_id_to_cancel = resp.job_response_items[0].job_id
    client.cancel_jobs(queue=queue, job_id=job_id_to_cancel, job_set_id=job_set_id)
    client.reprioritize_jobs(new_priority=2, queue=queue, job_set_id=job_set_id)