bool retry = false;

    /* The step had a hopefully temporary failure (e.g. network
       issue). Retry a number of times. */

        auto step_(step->state.lock());
        retry = step_->tries + 1 < maxTries;

        bool retry;
        {
            auto step_(step->state.lock());
            retry = step_->tries + 1 < maxTries;
        }
        if (retry) {
            pqxx::work txn(*conn);
            finishBuildStep(txn, result.startTime, result.stopTime, build->id,
                stepNr, machine->sshName, bssAborted, result.errorMsg);
            txn.commit();
            return true;
        }

    if (!retry) {
        auto steps_(steps.lock());
        steps_->erase(step->drvPath);
    }

    auto steps_(steps.lock());
    steps_->erase(step->drvPath);

            if (!retry) {
                /* Create failed build steps for every build that
                   depends on this. For cached failures, only create a
                   step for builds that don't have this step as
                   top-level (otherwise the user won't be able to see
                   what caused the build to fail). */
                for (auto build2 : dependents) {
                    if (build == build2) continue;
		    if (cachedFailure && build2->drvPath == step->drvPath) continue;
                    createBuildStep(txn, 0, build2, step, machine->sshName,
                        buildStepStatus, result.errorMsg, build->id);
                }

            /* Create failed build steps for every build that depends
               on this. For cached failures, only create a step for
               builds that don't have this step as top-level
               (otherwise the user won't be able to see what caused
               the build to fail). */
            for (auto build2 : dependents) {
                if (build == build2) continue;
                if (cachedFailure && build2->drvPath == step->drvPath) continue;
                createBuildStep(txn, 0, build2, step, machine->sshName,
                    buildStepStatus, result.errorMsg, build->id);

            if (!retry)
                for (auto build2 : dependents) {
                    printMsg(lvlError, format("marking build %1% as failed") % build2->id);
                    txn.parameterized
                        ("update Builds set finished = 1, busy = 0, buildStatus = $2, startTime = $3, stopTime = $4, isCachedBuild = $5 where id = $1")
                        (build2->id)
                        ((int) (build2->drvPath != step->drvPath && buildStatus == bsFailed ? bsDepFailed : buildStatus))
                        (result.startTime)
                        (result.stopTime)
                        (cachedFailure ? 1 : 0).exec();
                    build2->finishedInDB = true; // FIXME: txn might fail
                    nrBuildsDone++;
                }

            for (auto build2 : dependents) {
                printMsg(lvlError, format("marking build %1% as failed") % build2->id);
                txn.parameterized
                    ("update Builds set finished = 1, busy = 0, buildStatus = $2, startTime = $3, stopTime = $4, isCachedBuild = $5 where id = $1")
                    (build2->id)
                    ((int) (build2->drvPath != step->drvPath && buildStatus == bsFailed ? bsDepFailed : buildStatus))
                    (result.startTime)
                    (result.stopTime)
                    (cachedFailure ? 1 : 0).exec();
                build2->finishedInDB = true; // FIXME: txn might fail
                nrBuildsDone++;
            }

    if (!retry)
        for (auto build2 : dependents)
            if (build2->toplevel == step || result.status != RemoteResult::rrSuccess) {
                auto builds_(builds.lock());
                builds_->erase(build2->id);
            }

    for (auto build2 : dependents)
        if (build2->toplevel == step || result.status != RemoteResult::rrSuccess) {
            auto builds_(builds.lock());
            builds_->erase(build2->id);
        }

    if (!retry)
        destroyStep(step, result.status == RemoteResult::rrSuccess);

    destroyStep(step, result.status == RemoteResult::rrSuccess);

    return retry;

    return false;