Commit d7c7ee3f authored by BO ZHANG's avatar BO ZHANG 🏀
Browse files

remove p.info

parent 7f3cf5bd
Loading
Loading
Loading
Loading
+7 −9
Original line number Diff line number Diff line
@@ -127,6 +127,13 @@ class Pipeline:
            self.task = {}
        self.logger.info(f"task = {self.task}")

        # record basic information
        self.logger.info(f"DOCKER_IMAGE={self.docker_image}")
        self.logger.info(f"BUILD={self.build}")
        self.logger.info(f"CREATED={self.created}")
        self.logger.info(f"VERBOSE={self.verbose}")
        self.logger.info(f"INTTEST={self.inttest}")

    # warning operations
    @staticmethod
    def filter_warnings(level: str = "ignore"):
@@ -340,15 +347,6 @@ class Pipeline:
                    f"Invalid ref_cat: {task_ref_cat} not in {self.dfs1.catalog.all_catalog_names}"
                )

    # automatically log pipeline information
    def info(self):
        """Return pipeline information."""
        self.logger.info(f"DOCKER_IMAGE={self.docker_image}")
        self.logger.info(f"BUILD={self.build}")
        self.logger.info(f"CREATED={self.created}")
        self.logger.info(f"VERBOSE={self.verbose}")
        self.logger.info(f"INTTEST={self.inttest}")

    def exit(self, reason: str = None):
        """Exit pipeline with reason.