Bump black from 23.1.0 to 24.3.0

.github/workflows/test.yaml

@@ -7,7 +7,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        postgres_version: ['12', '13', '14']
+        postgres_version: ['14']
     services:
       postgres:
         image: postgres:${{ matrix.postgres_version }}

requirements-dev.txt

@@ -5,7 +5,7 @@ pytest-asyncio==0.21.0
 flake8==6.0.0
 responses==0.23.1
 mypy==1.1.1
-black==23.1.0
+black==24.3.0
 isort==5.12.0
 pre-commit==3.2.0
 freezegun==1.2.2

scripts/migrate_to_rapidpro/retry_requests.py

@@ -1,6 +1,7 @@
 """
 Looks for any failed requests, and retries them
 """
+
 import asyncio
 import json
 import sys

scripts/rapidpro/expire_flow_runs.py

@@ -0,0 +1,65 @@
+from csv import DictReader
+
+# AND (fr.session_id is null or fr.parent_uuid is null)
+# They're not linked to anything and the golang task just updates them.
+FILE = "expired_runs4.csv"
+
+input_file = DictReader(open(FILE))
+
+run_ids = []
+session_ids = []
+for row in input_file:
+    run_ids.append(row["run_id"])
+
+    if row["session_id"]:
+        session_ids.append(row["session_id"])
+
+
+print(len(run_ids))
+print(len(session_ids))
+
+print(
+    f"""UPDATE
+    flows_flowsession s
+    SET
+    timeout_on = NULL,
+    ended_on = NOW(),
+    status = 'X'
+    WHERE
+    id = ANY(ARRAY[{",".join(session_ids)}])
+"""
+)
+
+# print(f"""UPDATE
+# 		flows_flowrun fr
+# 	SET
+# 		is_active = FALSE,
+# 		exited_on = NOW(),
+# 		exit_type = 'E',
+# 		status = 'E',
+# 		modified_on = NOW()
+# 	WHERE
+# 		id = ANY(ARRAY[{",".join(run_ids)}])
+# """)
+
+"""
+UPDATE
+flows_flowrun fr
+SET
+is_active = FALSE,
+exited_on = NOW(),
+exit_type = 'E',
+status = 'E',
+modified_on = NOW()
+WHERE
+id = ANY(ARRAY[80689]);
+
+UPDATE
+flows_flowsession s
+SET
+timeout_on = NULL,
+ended_on = NOW(),
+status = 'X'
+WHERE
+id = ANY(ARRAY[26641])
+"""