def add_files_to_queue(queue, job_id, job_url, files, commit_sha):
    tasks = {}
    
    for (file_name, (content_b64, file_id)) in files.items():
        task_data = dict(job_id=job_id, url=job_url, name=file_name,
                         content_b64=content_b64, file_id=file_id,
                         commit_sha=commit_sha)
    
        # Spread tasks out over time.
        delay = timedelta(seconds=len(tasks))

        queue.put(task_data, expected_at=td2str(delay))
        tasks[file_id] = file_name
    
    return tasks
Make a new task for each file, return dict of file IDs to file names.
dataset/ETHPy150Open openaddresses/machine/openaddr/ci/__init__.py/add_files_to_queue