gistfile1.py

@task
def a_celery_task(pxid):
    try:
        do_something()
    except Exception:
        two_phase_commit.rollback_prepared(pxid)
    else:
        two_phase_commit.commit_prepared(pxid)

def defer_something():
    pxid = two_phase_commit.prepare_transaction()
    return a_celery_task.defer(pxid)