def conflict_task(bind=True, context=None, datetime=None): """Dummy task which injects a DataManager that votes a ConflictError.""" transaction.get().join(VoteExceptionDataManager())