data_dispatcher/api.py
def next_file(self, project_id, cpu_site=None):
        """Reserves next available file from the project
        
        Args:
            project_id (int): project id to reserve a file from
            cpu_site (str): optional, if specified, the file will be reserved according to the CPU/RSE proximity map
        
        Returns:
            dictionary with file information, or None if no file was available to be reserved. The method does not block and always returns immediately.
            Use `get_project()` to see if the project is done.
        """
        
        if self.WorkerID is None:
            raise ValueError("DataDispatcherClient must be initialized with Worker ID")
        url_tail = f"next_file?project_id={project_id}&worker_id={self.WorkerID}"
        if cpu_site:
            url_tail += f"&cpu_site={cpu_site}"
        return self.get(url_tail)
Reserves next available file from the project
        
        Args:
            project_id (int): project id to reserve a file from
            cpu_site (str): optional, if specified, the file will be reserved according to the CPU/RSE proximity map
        
        Returns:
            dictionary with file information, or None if no file was available to be reserved. The method does not block and always returns immediately.
            Use `get_project()` to see if the project is done.
        
Reserves next available file from the project
Reserves next available file from the project
def next_file(self, project_id, cpu_site=None):
        if self.WorkerID is None:
            raise ValueError("DataDispatcherClient must be initialized with Worker ID")
        url_tail = f"next_file?project_id={project_id}&worker_id={self.WorkerID}"
        if cpu_site:
            url_tail += f"&cpu_site={cpu_site}"
        return self.get(url_tail)
def next_file ( self , project_id , cpu_site = None ) : if self . WorkerID is None : raise ValueError ( "DataDispatcherClient must be initialized with Worker ID" ) url_tail = f"next_file?project_id={project_id}&worker_id={self.WorkerID}" if cpu_site : url_tail += f"&cpu_site={cpu_site}" return self . get ( url_tail )
Reserves next available file from the project
Reserves next available file from the project
"""Reserves next available file from the project
        
        Args:
            project_id (int): project id to reserve a file from
            cpu_site (str): optional, if specified, the file will be reserved according to the CPU/RSE proximity map
        
        Returns:
            dictionary with file information, or None if no file was available to be reserved. The method does not block and always returns immediately.
            Use `get_project()` to see if the project is done.
        """
dictionary with file information, or None if no file was available to be reserved. The method does not block and always returns immediately.
Use `get_project()` to see if the project is done.
dictionary with file information or None if no file was available to be reserved . The method does not block and always returns immediately . Use ` get_project () ` to see if the project is done .
self
project_id
project id to reserve a file from
project id to reserve a file from
cpu_site
optional, if specified, the file will be reserved according to the CPU/RSE proximity map
optional if specified the file will be reserved according to the CPU / RSE proximity map