Skip to content
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,6 @@ public interface QueuedWorkflowRepository extends PagingAndSortingRepository<Que
* @param retrievedFrom Details of where the queued workflow is from
*/
@Query("{tempRepresentation.retrievedFrom: ?0}")
void deleteByRetrievedFrom(GitDetails retrievedFrom);
void deleteByTempRepresentation_RetrievedFrom(GitDetails retrievedFrom);

}
Original file line number Diff line number Diff line change
Expand Up @@ -509,7 +509,7 @@ private void removeWorkflow(Workflow workflow) {
workflowRepository.delete(workflow);

// Remove any queued repositories pointing to the workflow
queuedWorkflowRepository.deleteByRetrievedFrom(workflow.getRetrievedFrom());
queuedWorkflowRepository.deleteByTempRepresentation_RetrievedFrom(workflow.getRetrievedFrom());
}

/**
Expand Down