16d1fd175f5ce804f4daa66da5d51e2dc3da1b36,test/test_spark.py,SparkTests,run,#SparkTests#Any#,70

Before Change

        warnings.simplefilter("module")

    def run(self, result=None):
        if int(os.getenv("OMPI_COMM_WORLD_RANK", 0)) != 0 or int(os.getenv("HOROVOD_RANK", 0)) != 0:
            // Running in MPI or Gloo with rank > 0, ignore.
            // Purposefully skip these silently
            return

After Change

    def run(self, result=None):
        // These unit tests should not be run with horovodrun as some tests
        // setup their own Horovod cluster, where both will then interfere.
        if "OMPI_COMM_WORLD_RANK" in os.environ or "HOROVOD_RANK" in os.environ:
            self.skipTest("These tests should not be executed via horovodrun, just pytest")

        super(SparkTests, self).run(result)

    
    Test that horovod.spark.run works properly in a simple setup using MPI.

Instances