def METHOD_NAME(context):
    assert "dagster-celery/priority" in context.op.tags
    assert context.op.tags["dagster-celery/priority"] == "1"
    context.log.info("Executing with priority 1")
    return True