(image: dict | None)
| 90 | |
| 91 | log("WRITER", "All writes complete. Waiting for poller to catch up...") |
| 92 | def format_image(image: dict | None) -> str: |
| 93 | if not image: |
| 94 | return "{}" |
| 95 | parts = [] |
| 96 | for k, v in sorted(image.items()): |
| 97 | typ = list(v.keys())[0] |
| 98 | parts.append(f"{k}={v[typ]}") |
| 99 | return " ".join(parts) |
| 100 | def poller_thread() -> None: |
| 101 | client = make_client() |
| 102 | streams_client = make_client("dynamodbstreams") |