Skip to content

Commit

Permalink
revert import changes
Browse files Browse the repository at this point in the history
  • Loading branch information
benclifford committed Jan 14, 2025
1 parent 4c027d4 commit faf4795
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 5 deletions.
4 changes: 2 additions & 2 deletions parsl/dataflow/futures.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@
from typing import Any, Optional, Sequence, Union

import parsl.app.app as app
import parsl.dataflow.taskrecord as tr
from parsl.app.futures import DataFuture
from parsl.dataflow.taskrecord import TaskRecord

logger = logging.getLogger(__name__)

Expand Down Expand Up @@ -54,7 +54,7 @@ class AppFuture(Future):
"""

def __init__(self, task_record: tr.TaskRecord) -> None:
def __init__(self, task_record: TaskRecord) -> None:
"""Initialize the AppFuture.
Args:
Expand Down
10 changes: 7 additions & 3 deletions parsl/dataflow/taskrecord.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,12 +3,16 @@
import datetime
import threading
from concurrent.futures import Future
from typing import Any, Callable, Dict, List, Optional, Sequence, Union

# only for type checking:
from typing import TYPE_CHECKING, Any, Callable, Dict, List, Optional, Sequence, Union

from typing_extensions import TypedDict

if TYPE_CHECKING:
from parsl.dataflow.futures import AppFuture

import parsl.dataflow.dflow as dflow
import parsl.dataflow.futures as pdf
from parsl.dataflow.states import States


Expand All @@ -25,7 +29,7 @@ class TaskRecord(TypedDict, total=False):

depends: List[Future]

app_fu: pdf.AppFuture
app_fu: AppFuture
"""The Future which was returned to the user when an app was invoked.
"""

Expand Down

0 comments on commit faf4795

Please sign in to comment.