umustafi commented on code in PR #4002:
URL: https://github.com/apache/gobblin/pull/4002#discussion_r1678512147
##########
gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/proc/LaunchDagProcTest.java:
##########
@@ -135,6 +138,10 @@ public void launchDagWithMultipleParallelJobs() throws
IOException, InterruptedE
flowCompilationValidationHelper);
launchDagProc.process(this.dagManagementStateStore);
+
+ // Verify adhoc flow spec will be removed from catalog
+
Mockito.verify(this.dagManagementStateStore,Mockito.times(2)).removeFlowSpec(any());
Review Comment:
I couldn't switch to testng because you can't use @Before/AfterClass
annotations with nonstatic methods (for setUp and teardown). Using that
function didn't work but resetting the DGMSS between methods worked.
--
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]
