The workflow automatically deletes assets based on "rejected" status and
lastModifiedOn fields.

Question

I want to design a workflow that can automatically detect “rejected” assets, assets are not been modified in the last 3 months, and delete them. Do you have any advice on that? Thank you so much

arthurburkhardt · Answer

You can do a workflow running on a schedule to look for all rejected assets, filter on their last update date, then find if there has been any activity in the last 90 days (edit attributes, relations, responsibilities, etc.)

Here’s an untested code quickly wrote:

import com.collibra.dgc.core.api.dto.activitystream.FindActivitiesRequest
import com.collibra.dgc.core.api.dto.instance.asset.FindAssetsRequest

def ninetyDaysAgo = System.currentTimeMillis() - (90 * 24 * 60 * 60 * 1000)

def rejectedAssets = assetApi.findAssets(FindAssetsRequest.builder()
	.statusIds([rejectedStatusUuid])
	.build()).results.findAll{it.lastModifiedOn < ninetyDaysAgo}

def activitiesSinceNinetyDays = rejectedAssets.collect{
	def activityCount = activityStreamApi.getActivities(FindActivitiesRequest.builder()
		.contextId(it.id)
		.startDate(ninetyDaysAgo)
		.build()).results.size()
	[assetId: it.id,
	 assetName: it.name,
	 activityCount: activityCount]
}

activitiesSinceNinetyDays.each{
	if (it.activityCount > 0) {
		loggerApi.info("Asset ${it.assetName}: Skipping delete - There has been ${it.activityCount} activities on that asset in the last 90 days.")
	} else {
		loggerApi.info("Delete asset: ${it.assetName}")
		assetApi.removeAsset(it.assetId)
	}
}

arthurburkhardt · Answer

You can do a workflow running on a schedule to look for all rejected assets, filter on their last update date, then find if there has been any activity in the last 90 days (edit attributes, relations, responsibilities, etc.)

Here’s an untested code quickly wrote:

import com.collibra.dgc.core.api.dto.activitystream.FindActivitiesRequest
import com.collibra.dgc.core.api.dto.instance.asset.FindAssetsRequest

def ninetyDaysAgo = System.currentTimeMillis() - (90 * 24 * 60 * 60 * 1000)

def rejectedAssets = assetApi.findAssets(FindAssetsRequest.builder()
	.statusIds([rejectedStatusUuid])
	.build()).results.findAll{it.lastModifiedOn < ninetyDaysAgo}

def activitiesSinceNinetyDays = rejectedAssets.collect{
	def activityCount = activityStreamApi.getActivities(FindActivitiesRequest.builder()
		.contextId(it.id)
		.startDate(ninetyDaysAgo)
		.build()).results.size()
	[assetId: it.id,
	 assetName: it.name,
	 activityCount: activityCount]
}

activitiesSinceNinetyDays.each{
	if (it.activityCount > 0) {
		loggerApi.info("Asset ${it.assetName}: Skipping delete - There has been ${it.activityCount} activities on that asset in the last 90 days.")
	} else {
		loggerApi.info("Delete asset: ${it.assetName}")
		assetApi.removeAsset(it.assetId)
	}
}

1	Grant Rollerson SUNCORP CORPORATE SERVICES PTY LTD
2	Tom Friesen Algonquin College
3	SB S Benson Plus3 IT
4	S stefan_busch
5	Brian Lloyd USA TODAY Co.
6	D daverichard

The workflow automatically deletes assets based on "rejected" status and lastModifiedOn fields.