phet commented on code in PR #3899:
URL: https://github.com/apache/gobblin/pull/3899#discussion_r1542176011
##########
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/DagActionStore.java:
##########
@@ -80,6 +80,14 @@ public DagAction updateFlowExecutionId(long eventTimeMillis)
{
*/
boolean exists(String flowGroup, String flowName, String flowExecutionId,
DagActionType dagActionType) throws IOException, SQLException;
+ /**
+ * check if the dag action exists in {@link DagActionStore} using {@link
DagAction} to identify dag and specific
+ * action value
+ * @throws IOException
+ * @return true if we successfully delete one record, return false if the
record does not exist
+ */
+ boolean exists(DagAction dagAction) throws IOException, SQLException;
+
Review Comment:
I don't believe there's a need for this method
--
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]
