this repo has no description
bsky-activity.py: use commit time for users, not now
+4
-4
+4
-4
bsky-activity.py
+4
-4
bsky-activity.py
···
55
55
continue
56
56
57
57
repo_did = commit['repo']
58
-
now = datetime.now(timezone.utc)
58
+
repo_update_time = datetime.strptime(commit['time'], '%Y-%m-%dT%H:%M:%S.%fZ').replace(tzinfo=timezone.utc)
59
59
db_cnx.execute(
60
60
'insert into users values (:did, :ts) on conflict (did) do update set ts = :ts',
61
-
{'did': repo_did, 'ts': now.timestamp()}
61
+
{'did': repo_did, 'ts': repo_update_time.timestamp()}
62
62
)
63
63
64
64
redis_pipe \
···
67
67
68
68
op_count += 1
69
69
if op_count % 500 == 0:
70
+
now = datetime.now(timezone.utc)
70
71
payload_seq = commit['seq']
71
-
payload_time = datetime.strptime(commit['time'], '%Y-%m-%dT%H:%M:%S.%fZ').replace(tzinfo=timezone.utc)
72
-
payload_lag = now - payload_time
72
+
payload_lag = now - repo_update_time
73
73
74
74
sys.stdout.write(f'seq: {payload_seq}, lag: {payload_lag.total_seconds()}\n')
75
75
redis_pipe.set('dev.edavis.muninsky.seq', payload_seq)