diff --git a/pkg/hydrator/hydrator.go b/pkg/hydrator/hydrator.go index f7b8bf5..e15349c 100644 --- a/pkg/hydrator/hydrator.go +++ b/pkg/hydrator/hydrator.go @@ -228,6 +228,7 @@ func (h *Hydrator) flattenFullProfile(profile *bsky.ActorDefs_ProfileViewDetaile result["FollowersCount"] = profile.FollowersCount result["FollowsCount"] = profile.FollowsCount result["PostsCount"] = profile.PostsCount + result["IndexedAt"] = profile.IndexedAt return } diff --git a/pkg/output/bq/schema/schema.go b/pkg/output/bq/schema/schema.go index 9c64b39..f5b3e5e 100644 --- a/pkg/output/bq/schema/schema.go +++ b/pkg/output/bq/schema/schema.go @@ -76,6 +76,11 @@ func GetSchema() bigquery.Schema { "name": "DisplayName", "type": "STRING" }, + { + "mode": "NULLABLE", + "name": "IndexedAt", + "type": "TIMESTAMP" + }, { "mode": "NULLABLE", "name": "FollowersCount", @@ -123,6 +128,11 @@ func GetSchema() bigquery.Schema { "name": "DisplayName", "type": "STRING" }, + { + "mode": "NULLABLE", + "name": "IndexedAt", + "type": "TIMESTAMP" + }, { "mode": "NULLABLE", "name": "FollowersCount",