Merge pull request #3575 from jmchilton/pulsar_default_fix

[17.01] Fix default for Pulsar option "dependency_resolution" to match documentation.
This commit is contained in:
Martin Cech
2017-02-07 16:03:25 -05:00
committed by GitHub
+1 -1
View File
@@ -615,7 +615,7 @@ class PulsarJobRunner( AsynchronousJobRunner ):
@staticmethod
def __dependency_resolution( pulsar_client ):
dependency_resolution = pulsar_client.destination_params.get( "dependency_resolution", "local" )
dependency_resolution = pulsar_client.destination_params.get( "dependency_resolution", "remote" )
if dependency_resolution not in ["none", "local", "remote"]:
raise Exception("Unknown dependency_resolution value encountered %s" % dependency_resolution)
return dependency_resolution