From: Zack M. Davis <code@zackmdavis.net>
Date: Wed, 15 Jul 2026 23:54:40 +0000 (-0700)
Subject: Pelican scheduler
X-Git-Url: https://zackmdavis.net/blog/source?a=commitdiff_plain;h=ba0355bab291f7cd9310927709eb6775dee8098e;p=An_Algorithmic_Lucidity.git

Pelican scheduler

Claude wrote a new docstring and added the pedantry about .pop, but
this is basically my original scheduler from 2017.
---

diff --git a/provisioning/pelican_scheduler.py b/provisioning/pelican_scheduler.py
new file mode 100755
index 0000000..61d0f50
--- /dev/null
+++ b/provisioning/pelican_scheduler.py
@@ -0,0 +1,106 @@
+#!/usr/bin/env python3
+
+"""Git post-receive hook: sync the working checkout and rebuild the site,
+scheduling future-dated posts to go live automatically via `at`. Adapted from
+Ultimately_Untrue_Thought/provisioning/pelican_scheduler.py for the
+An_Algorithmic_Lucidity blogmistress deployment.
+
+The bare repo's hooks/post-receive is a symlink to this file's copy in the
+working checkout (matching the UUT setup), not a standalone copy: the working
+checkout already exists (cloned once, ahead of time) before the hook is ever
+wired up, so there's no bootstrap-ordering problem, and a symlink means a
+future edit to this file, once pushed, takes effect on the very next deploy
+instead of silently going stale."""
+
+import datetime
+import os
+import re
+import subprocess
+
+WORKING_REPO = "/home/blogmistress/An_Algorithmic_Lucidity/working"
+INPUT_DIR = os.path.join(WORKING_REPO, "content")
+OUTPUT_DIR = "/home/blogmistress/An_Algorithmic_Lucidity/output"
+PUBLISH_CONF = os.path.join(WORKING_REPO, "publishconf.py")
+SITEGEN_COMMAND = "bash -c 'cd {} && source .venv/bin/activate && pelican {} -o {} -s {}'".format(
+    WORKING_REPO, INPUT_DIR, OUTPUT_DIR, PUBLISH_CONF)
+
+DATELINE_REGEX = re.compile(r"^Date: *(\d{4}-\d{2}-\d{2} \d{2}:\d{2}) *$",
+                            re.MULTILINE)
+JOBLINE_REGEX = re.compile(r"\d+\s\w{3} (\w{3} +\d{1,2} \d{2}:\d{2}:\d{2} \d{4})")
+
+def get_future_publication_times():
+    now = datetime.datetime.now()
+    times = set()
+    for path, _dirnames, filenames in os.walk(INPUT_DIR):
+        if path.endswith("drafts"):
+            continue
+        for filename in filenames:
+            if not filename.endswith(".md"):
+                continue
+            with open(os.path.join(path, filename)) as post_file:
+                match = DATELINE_REGEX.search(post_file.read())
+                if match:
+                    time = datetime.datetime.strptime(match.group(1),
+                                                      "%Y-%m-%d %H:%M")
+                    if time > now:
+                        times.add(time)
+    return times
+
+
+def get_extant_at_job_times():
+    times = set()
+    result = subprocess.run(["atq"], stdout=subprocess.PIPE)
+    job_lines = result.stdout.decode('utf8').split('\n')
+    for job_line in job_lines:
+        match = JOBLINE_REGEX.match(job_line)
+        if match:
+            times.add(datetime.datetime.strptime(match.group(1),
+                                                 "%b %d %H:%M:%S %Y"))
+    return times
+
+
+def schedule(command, when):
+    timestamp = when.strftime("%H:%M %Y-%m-%d")
+    at_command = ['at', timestamp]
+    at = subprocess.Popen(
+        at_command,
+        stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE
+    )
+    at.communicate(command.encode())
+
+
+def main():
+    # sync our "working" repo with the bare one
+
+    # but first, don't let the fact that this is running as a hook on the bare
+    # repo confuse us
+    our_env = os.environ.copy()
+    our_env.pop('GIT_DIR', None)  # (.pop with a default, unlike the original's
+                                  # `del`, so this doesn't raise if GIT_DIR
+                                  # isn't set)
+
+    for git_cmd in [["git", "fetch", "origin"],
+                    ["git", "reset", "--hard", "origin/master"]]:
+        subprocess.run(git_cmd, cwd=WORKING_REPO, env=our_env)
+
+    # sitegen now! (even if there are no posts to queue, we can at least update
+    # /drafts/) and make any back-edits to published posts live
+    subprocess.run(SITEGEN_COMMAND,
+                   # XXX: `shell=True` is contrary to the moral law
+                   shell=True)
+
+    # look for scheduled future posts
+    future_publication_times = get_future_publication_times()
+
+    # look at atq
+    extant_at_job_times = get_extant_at_job_times()
+
+    # if there are future posts that don't have an atq entry, schedule a
+    # site-regen at that time
+    to_schedule = future_publication_times - extant_at_job_times
+    for time in to_schedule:
+        schedule(SITEGEN_COMMAND, time)
+
+
+if __name__ == "__main__":
+    main()