pratapaditya04 commented on code in PR #4098:
URL: https://github.com/apache/gobblin/pull/4098#discussion_r1957707447
##########
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 think, we can just create it in TemporalLauncher, and the worker can ask
temporalLaucher for the queueName.
Let me sync with you offline on this.
--
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]
