819e822c8acb54a671653fa552e1f130ac92efc4,tests/test_pipelines/test_models.py,TestOperationRunModel,test_is_upstream_done,#TestOperationRunModel#,683

Before Change

        assert operation_run.is_upstream_done is False

        // A running upstream
        OperationRunStatus.objects.create(status=OperationStatuses.RUNNING,
                                          operation_run=upstream_run1)
        assert operation_run.is_upstream_done is False

        // A failed upstream
        OperationRunStatus.objects.create(status=OperationStatuses.FAILED,
                                          operation_run=upstream_run1)
        assert operation_run.is_upstream_done is True

        // Add skipped upstream
        upstream_run2 = OperationRunFactory()
        operation_run.upstream_runs.set([upstream_run2])
        OperationRunStatus.objects.create(status=OperationStatuses.SKIPPED,
                                          operation_run=upstream_run2)
        assert operation_run.is_upstream_done is True

        // Add succeeded upstream
        upstream_run3 = OperationRunFactory()
        operation_run.upstream_runs.set([upstream_run3])
        OperationRunStatus.objects.create(status=OperationStatuses.SUCCEEDED,
                                          operation_run=upstream_run3)
        assert operation_run.is_upstream_done is True

        // Many done upstreams
        operation_run.upstream_runs.set(

After Change

        assert operation_run.is_upstream_done is False

        // A running upstream
        upstream_run1.status = OperationStatuses.RUNNING
        upstream_run1.save()
        assert operation_run.is_upstream_done is False

        // A failed upstream
        upstream_run1.status = OperationStatuses.FAILED
        upstream_run1.save()
        assert operation_run.is_upstream_done is True

        // Add skipped upstream
        upstream_run2 = OperationRunFactory()

Instances