tasks.py 406 B

123456789101112
  1. from celery import shared_task
  2. from organizations_ext.models import Organization
  3. from .assemble import assemble_artifacts
  4. @shared_task
  5. def assemble_artifacts_task(org_id, version, checksum, chunks, **kwargs):
  6. """
  7. Creates release files from an uploaded artifact bundle.
  8. """
  9. organization = Organization.objects.get(pk=org_id)
  10. assemble_artifacts(organization, version, checksum, chunks)