Skip to content

Commit

Permalink
build fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
RyanHolstien committed Jul 13, 2023
1 parent 7999154 commit 34b1e2b
Showing 1 changed file with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,8 @@
import com.linkedin.metadata.config.PreProcessHooks;
import com.linkedin.metadata.entity.AspectDao;
import com.linkedin.metadata.entity.EntityService;
import com.linkedin.metadata.entity.EntityServiceImpl;
import com.linkedin.metadata.entity.UpdateAspectResult;
import com.linkedin.metadata.event.EventProducer;
import com.linkedin.metadata.models.AspectSpec;
import com.linkedin.metadata.models.registry.EntityRegistry;
Expand Down Expand Up @@ -48,7 +50,7 @@ public void setup() {
_entityRegistry = new MockEntityRegistry();
_updateIndicesService = mock(UpdateIndicesService.class);
_preProcessHooks = mock(PreProcessHooks.class);
_entityService = new EntityService(_aspectDao, _producer, _entityRegistry, false, _updateIndicesService, _preProcessHooks);
_entityService = new EntityServiceImpl(_aspectDao, _producer, _entityRegistry, false, _updateIndicesService, _preProcessHooks);
_authorizer = mock(Authorizer.class);
_aspectResource.setAuthorizer(_authorizer);
_aspectResource.setEntityService(_entityService);
Expand Down Expand Up @@ -77,7 +79,7 @@ public void testAsyncDefaultAspects() throws URISyntaxException {
reset(_producer, _aspectDao);

when(_aspectDao.runInTransactionWithRetry(any(), anyInt()))
.thenReturn(new EntityService.UpdateAspectResult(urn, null, properties, null, null, null, null, 0));
.thenReturn(new UpdateAspectResult(urn, null, properties, null, null, null, null, 0));
_aspectResource.ingestProposal(mcp, "false");
verify(_producer, times(5)).produceMetadataChangeLog(eq(urn), any(AspectSpec.class), any(MetadataChangeLog.class));
verifyNoMoreInteractions(_producer);
Expand Down

0 comments on commit 34b1e2b

Please sign in to comment.