Github user vanzin commented on the issue: https://github.com/apache/spark/pull/19134 For python I think you just do what kinesis does: ``` # Must be same as the variable and condition defined in KinesisTestUtils.scala kinesis_test_environ_var = "ENABLE_KINESIS_TESTS" are_kinesis_tests_enabled = os.environ.get(kinesis_test_environ_var) == '1' ``` The comment is misleading though, since that variable is set in `modules.py` which you are already modifying.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org