celery_migration

@signals.task_success.connect(sender='this.task.location')
  def migrations_success_notifcation(
    result,
    *args,
    **kwargs
  ):
    print(result)

  @signals.task_failure.connect(sender='this.task.location')
  def migrations_failure_notification(
    task_id,
    exception,
    traceback,
    *args,
    **kwargs
  ):
    logging.info(
        task_id,
        exception,
        args,
        kwargs,
        traceback
    )

  @app.task
  def run_migrations(**kwargs):
    # The following print will log just fine
    print('HELOOOOOO TASK')

    execute_from_command_line([
        "../../manage.py",
        "migrate"
    ])