diff --git a/src/main/java/org/avniproject/etl/repository/sync/MediaTableSyncAction.java b/src/main/java/org/avniproject/etl/repository/sync/MediaTableSyncAction.java index a7ba787..53b2e8a 100644 --- a/src/main/java/org/avniproject/etl/repository/sync/MediaTableSyncAction.java +++ b/src/main/java/org/avniproject/etl/repository/sync/MediaTableSyncAction.java @@ -47,7 +47,7 @@ public void perform(TableMetadata tableMetadata, Date lastSyncTime, Date dataSyn } currentSchemaMetadata.getTableMetadata().forEach(thisTableMetadata -> { - List mediaColumns = thisTableMetadata.findColumnsMatchingConceptType(ColumnMetadata.ConceptType.Image, ColumnMetadata.ConceptType.Video); + List mediaColumns = thisTableMetadata.findColumnsMatchingConceptType(ColumnMetadata.ConceptType.Image, ColumnMetadata.ConceptType.Video, ColumnMetadata.ConceptType.Audio, ColumnMetadata.ConceptType.File); mediaColumns.forEach(mediaColumn -> { insertData(tableMetadata, thisTableMetadata, mediaColumn, lastSyncTime, dataSyncBoundaryTime); });