Adapt for pendulum 3

seung-lab · Feb 19, 2024 · fe27605 · fe27605
1 parent e6f3552
commit fe27605
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/dags/compute_metrics_dag.py b/dags/compute_metrics_dag.py
@@ -82,7 +82,7 @@ def resource_summary(dag_run):
                 messages += [f"GCS api call to bucket `{b}`: {api_summary}"]
 
         if messages:
-            slack_message("\n".join([f"*Compute resources used by* `{target_dag_id}` *in {pendulum.period(start_time, end_time).in_words()}*:"] + messages), broadcast=True)
+            slack_message("\n".join([f"*Compute resources used by* `{target_dag_id}` *in {pendulum.interval(start_time, end_time).in_words()}*:"] + messages), broadcast=True)
 
     res_op = PythonOperator(
                 task_id='resource_summary',

diff --git a/docker/Dockerfile b/docker/Dockerfile
@@ -44,7 +44,6 @@ RUN savedAptMark="$(apt-mark showmanual)" \
     && pip install --no-cache-dir --compile --global-option=build git+https://github.com/seung-lab/chunk_iterator#egg=chunk-iterator \
     && pip install --no-cache-dir igneous-pipeline \
     && pip install --no-cache-dir "apache-airflow[celery,postgres,rabbitmq,docker,slack,google,statsd]==${AIRFLOW_VERSION}" --constraint "${CONSTRAINT_URL}" \
-    && pip install --no-cache-dir pendulum==2.1.2 \
     && mkdir -p ${AIRFLOW_HOME}/version \
     && groupadd -r docker \
     && groupadd -r ${AIRFLOW_USER} \