Trying some pipeline overloading for standalone
This commit is contained in:
@@ -2278,13 +2278,8 @@ func main() {
|
|||||||
if os.Getenv("SHUFFLE_PIPELINE_STANDALONE") == "true" {
|
if os.Getenv("SHUFFLE_PIPELINE_STANDALONE") == "true" {
|
||||||
log.Printf("[INFO] Allowing use of standalone pipeline (tenzir). URL: %s", pipelineUrl)
|
log.Printf("[INFO] Allowing use of standalone pipeline (tenzir). URL: %s", pipelineUrl)
|
||||||
|
|
||||||
//if os.Getenv("SHUFFLE_SKIP_PIPELINES") == "false" {
|
os.Setenv("SHUFFLE_SKIP_PIPELINES", "false")
|
||||||
// os.Setenv("SHUFFLE_SKIP_PIPELINES", "true")
|
os.Setenv("SHUFFLE_PIPELINE_ENABLED", "true")
|
||||||
//}
|
|
||||||
|
|
||||||
//if os.Getenv("SHUFFLE_PIPELINE_ENABLED") == "true" {
|
|
||||||
// os.Setenv("SHUFFLE_PIPELINE_ENABLED", "false")
|
|
||||||
//}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Block until a signal is received
|
// Block until a signal is received
|
||||||
|
|||||||
Reference in New Issue
Block a user