libs/libcommon/src/libcommon/state.py [280:300]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            step="get_dataset_level_artifact_states",
        ):
            self.artifact_state_by_step = {
                processing_step.name: ArtifactState(
                    processing_step=processing_step,
                    dataset=self.dataset,
                    revision=self.revision,
                    config=None,
                    split=None,
                    pending_jobs_df=pending_jobs_df[
                        (pending_jobs_df["revision"] == self.revision)
                        & (pending_jobs_df["config"].isnull())
                        & (pending_jobs_df["split"].isnull())
                        & (pending_jobs_df["type"] == processing_step.job_type)
                    ],
                    cache_entries_df=cache_entries_df[
                        (cache_entries_df["kind"] == processing_step.cache_kind)
                        & (cache_entries_df["config"].isnull())
                        & (cache_entries_df["split"].isnull())
                    ],
                )
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



libs/libcommon/src/libcommon/state.py [350:370]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            step="get_dataset_level_artifact_states",
        ):
            self.artifact_state_by_step = {
                processing_step.name: ArtifactState(
                    processing_step=processing_step,
                    dataset=self.dataset,
                    revision=self.revision,
                    config=None,
                    split=None,
                    pending_jobs_df=pending_jobs_df[
                        (pending_jobs_df["revision"] == self.revision)
                        & (pending_jobs_df["config"].isnull())
                        & (pending_jobs_df["split"].isnull())
                        & (pending_jobs_df["type"] == processing_step.job_type)
                    ],
                    cache_entries_df=cache_entries_df[
                        (cache_entries_df["kind"] == processing_step.cache_kind)
                        & (cache_entries_df["config"].isnull())
                        & (cache_entries_df["split"].isnull())
                    ],
                )
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -