Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Do not store DFK in PolledExecutorFacade #3320

Merged
merged 1 commit into from
Apr 8, 2024
Merged

Do not store DFK in PolledExecutorFacade #3320

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 3 additions & 4 deletions parsl/jobs/job_status_poller.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,17 +19,16 @@
class PolledExecutorFacade:
def __init__(self, executor: BlockProviderExecutor, dfk: Optional["parsl.dataflow.dflow.DataFlowKernel"] = None):
self._executor = executor
self._dfk = dfk
self._interval = executor.status_polling_interval
self._last_poll_time = 0.0
self._status = {} # type: Dict[str, JobStatus]

# Create a ZMQ channel to send poll status to monitoring
self.monitoring_enabled = False
if self._dfk and self._dfk.monitoring is not None:
if dfk and dfk.monitoring is not None:
self.monitoring_enabled = True
hub_address = self._dfk.hub_address
hub_port = self._dfk.hub_zmq_port
hub_address = dfk.hub_address
hub_port = dfk.hub_zmq_port
context = zmq.Context()
self.hub_channel = context.socket(zmq.DEALER)
self.hub_channel.set_hwm(0)
Expand Down
Loading