Blazer-007 commented on code in PR #4098:
URL: https://github.com/apache/gobblin/pull/4098#discussion_r1957701813
##########
gobblin-temporal/src/main/java/org/apache/gobblin/temporal/GobblinTemporalConfigurationKeys.java:
##########
@@ -74,4 +80,22 @@ public interface GobblinTemporalConfigurationKeys {
String DYNAMIC_SCALING_POLLING_INTERVAL_SECS = DYNAMIC_SCALING_PREFIX +
"polling.interval.seconds";
int DEFAULT_DYNAMIC_SCALING_POLLING_INTERVAL_SECS = 60;
+
+ /**
+ * Generates a unique task queue name for Gobblin Temporal task queue.
+ * The task queue name is created by concatenating a prefix from the
configuration
+ * with a randomly generated UUID.
+ *
+ * @param config the configuration object from which to retrieve the queue
prefix
+ * @return a unique task queue name
+ * @throws NullPointerException if the provided config is null
+ */
+ static String getTemporalTaskQueueName(Config config) {
+ Objects.requireNonNull(config, "Config must not be null");
+
+ final String queuePrefix =
+ ConfigUtils.getString(config,
GobblinTemporalConfigurationKeys.GOBBLIN_TEMPORAL_TASK_QUEUE,
+
GobblinTemporalConfigurationKeys.DEFAULT_GOBBLIN_TEMPORAL_TASK_QUEUE);
+ return queuePrefix + UUID.randomUUID();
Review Comment:
I mean taskQueueName should be same for Worker and Workflow & Launcher both
here if it is called from different places it will be different values
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
