personal memory agent
Merge branch 'hopper-am7q6jzg-dream-updated-flag'
+30
-1
+30
-1
think/dream.py
+30
-1
think/dream.py
···
13
13
import sys
14
14
import threading
15
15
import time
16
-
from datetime import datetime, timedelta
16
+
from datetime import date, datetime, timedelta
17
17
from pathlib import Path
18
18
19
19
from think.activities import get_activity_output_path, load_activity_records
···
36
36
get_rev,
37
37
iso_date,
38
38
setup_cli,
39
+
updated_days,
39
40
)
40
41
41
42
# Module-level callosum connection for event emission
···
1418
1419
metavar="N",
1419
1420
help="Max concurrent agents per priority group (0=unlimited, default: 2)",
1420
1421
)
1422
+
parser.add_argument(
1423
+
"--updated",
1424
+
action="store_true",
1425
+
help="List days with pending daily processing and exit",
1426
+
)
1421
1427
return parser
1422
1428
1423
1429
···
1426
1432
1427
1433
parser = parse_args()
1428
1434
args = setup_cli(parser)
1435
+
1436
+
if args.updated:
1437
+
incompatible = []
1438
+
if args.day:
1439
+
incompatible.append("--day")
1440
+
if args.segment:
1441
+
incompatible.append("--segment")
1442
+
if args.run:
1443
+
incompatible.append("--run")
1444
+
if args.facet:
1445
+
incompatible.append("--facet")
1446
+
if args.activity:
1447
+
incompatible.append("--activity")
1448
+
if args.flush:
1449
+
incompatible.append("--flush")
1450
+
if args.segments:
1451
+
incompatible.append("--segments")
1452
+
if incompatible:
1453
+
parser.error(f"--updated is incompatible with {', '.join(incompatible)}")
1454
+
today = date.today().strftime("%Y%m%d")
1455
+
for d in updated_days(exclude={today}):
1456
+
print(d)
1457
+
sys.exit(0)
1429
1458
1430
1459
day = args.day
1431
1460
if day is None: