@celery.task
def device_software_updates():
    callback = software_updates.subtask()
header = [installed_device_software.subtask(device_id),
    latest_device_software.s(device_id)]
result = chord(header)(callback)
return result.get()
Объединение результатов работы в celery