def METHOD_NAME(self, user):
    if self.lostconfig.worker_management == 'dynamic':
        if self.lostconfig.dask_spawn_as_proxy_user:
            # Spawn cluster as specific proxy user
            cluster = self.lostconfig.DaskCluster(user=_user_key(user), **self.lostconfig.cluster_arguments)
        else:
            cluster = self.lostconfig.DaskCluster(**self.lostconfig.cluster_arguments)
        client = self.lostconfig.DaskClient(cluster)
        self.session[_user_key(user)] = {
            'client': client,
            'timestamp': datetime.utcnow()
        }
    else:
        raise Exception('Can only use create_cluster in dynamic worker management mode!')
    return cluster, client