From 4835c70e18c21341d8cb179ca7b04ec965903a98 Mon Sep 17 00:00:00 2001 From: Ronnie Dutta <61982285+MetRonnie@users.noreply.github.com> Date: Tue, 23 Jul 2024 12:28:10 +0100 Subject: [PATCH] Invest --- .github/workflows/test_fast.yml | 11 +---------- cylc/flow/cycling/loader.py | 2 ++ cylc/flow/taskdef.py | 5 +++++ 3 files changed, 8 insertions(+), 10 deletions(-) diff --git a/.github/workflows/test_fast.yml b/.github/workflows/test_fast.yml index cd92c67517a..a069011b0f9 100644 --- a/.github/workflows/test_fast.yml +++ b/.github/workflows/test_fast.yml @@ -25,7 +25,7 @@ jobs: env: TZ: ${{ matrix.time-zone }} - PYTEST_ADDOPTS: --cov --cov-append -n 5 --color=yes + PYTEST_ADDOPTS: -n 5 --color=yes steps: - name: Checkout @@ -36,15 +36,6 @@ jobs: with: python-version: ${{ matrix.python-version }} - - name: Apt-Get Install - if: startsWith(matrix.os, 'ubuntu') - run: | - sudo apt-get update - sudo apt-get install -y sqlite3 - - - name: Patch DNS - uses: cylc/release-actions/patch-dns@v1 - - name: Install run: | pip install -e ."[all]" diff --git a/cylc/flow/cycling/loader.py b/cylc/flow/cycling/loader.py index 71c175eb97a..88b0fbb1f38 100644 --- a/cylc/flow/cycling/loader.py +++ b/cylc/flow/cycling/loader.py @@ -21,6 +21,7 @@ from typing import Optional, Type, overload +from cylc.flow import LOG from cylc.flow.cycling import PointBase, integer, iso8601 from metomi.isodatetime.data import Calendar @@ -111,6 +112,7 @@ def get_interval_cls(cycling_type=None): """Return the cylc.flow.cycling.IntervalBase-derived class we're using.""" if cycling_type is None: cycling_type = DefaultCycler.TYPE + LOG.critical(f"cycling type: {cycling_type}") return INTERVALS[cycling_type] diff --git a/cylc/flow/taskdef.py b/cylc/flow/taskdef.py index 448844c8cc3..a6c0ddbae49 100644 --- a/cylc/flow/taskdef.py +++ b/cylc/flow/taskdef.py @@ -19,6 +19,7 @@ from collections import deque from typing import TYPE_CHECKING +from cylc.flow import LOG import cylc.flow.flags from cylc.flow.exceptions import TaskDefError from cylc.flow.task_id import TaskID @@ -30,16 +31,20 @@ ) if TYPE_CHECKING: + from cylc.flow.task_trigger import TaskTrigger from cylc.flow.cycling import PointBase def generate_graph_children(tdef, point): """Determine graph children of this task at point.""" + if str(point) == "+P0": + LOG.critical(f"point is +P0; {type(point)}") graph_children = {} for seq, dout in tdef.graph_children.items(): for output, downs in dout.items(): if output not in graph_children: graph_children[output] = [] + trigger: 'TaskTrigger' for name, trigger in downs: child_point = trigger.get_child_point(point, seq) is_abs = (