Modified cross language pipeline unified worker logic

Author: TongruiLi

runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java

@@ -1245,7 +1245,7 @@ public DataflowPipelineJob run(Pipeline pipeline) {
     // to Runner v2.
     if (DataflowRunner.isMultiLanguagePipeline(pipeline) || includesTransformUpgrades(pipeline)) {
       List<String> experiments = firstNonNull(options.getExperiments(), Collections.emptyList());
-      if (!experiments.contains("use_runner_v2") || !experiments.contains("enable_portable_runner")) {
+      if (!useUnifiedWorker(options)) {
         LOG.info(
             "Automatically enabling Dataflow Runner v2 since the pipeline used cross-language"
                 + " transforms or pipeline needed a transform upgrade.");