Skip to content

Commit

Permalink
Add pre-commit
Browse files Browse the repository at this point in the history
  • Loading branch information
talsperre committed Jun 26, 2024
1 parent 4ebcbe2 commit 7919204
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 5 deletions.
14 changes: 10 additions & 4 deletions metaflow/system/system_monitor.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,11 +26,17 @@ def update_context(self, context: Dict[str, Any]):
"""
from metaflow.sidecar import Message, MessageTypes

self._context.update(context)
self.monitor.send(Message(MessageTypes.MUST_SEND, {
"is_context_updated": True,
**self._context,
}))
self.monitor.send(
Message(
MessageTypes.MUST_SEND,
{
"is_context_updated": True,
**self._context,
},
)
)

def init_system_monitor(
self, flow_name: str, monitor: "metaflow.monitor.NullMonitor"
Expand Down
2 changes: 1 addition & 1 deletion metaflow/task.py
Original file line number Diff line number Diff line change
Expand Up @@ -317,7 +317,7 @@ def clone_only(
level="info",
module="metaflow.task",
name="clone",
payload={**task_payload,"msg": msg},
payload={**task_payload, "msg": msg},
)
# If we actually have to do the clone ourselves, proceed...
clone_task_helper(
Expand Down

0 comments on commit 7919204

Please sign in to comment.