Skip to content

Commit 8588209

Browse files
committed
A bit of extra cleanup
1 parent 35949d7 commit 8588209

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

worker_versioning/activities.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,10 @@ class IncompatibleActivityInput:
1414
@activity.defn
1515
async def some_activity(called_by: str) -> str:
1616
"""Basic activity for the workflow."""
17-
return f"SomeActivity called by {called_by}"
17+
return f"some_activity called by {called_by}"
1818

1919

2020
@activity.defn
2121
async def some_incompatible_activity(input_data: IncompatibleActivityInput) -> str:
2222
"""Incompatible activity that takes different input."""
23-
return f"SomeIncompatibleActivity called by {input_data.called_by} with {input_data.more_data}"
23+
return f"some_incompatible_activity called by {input_data.called_by} with {input_data.more_data}"

worker_versioning/app.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,6 @@ async def wait_for_worker_and_make_current(client: Client, build_id: str) -> Non
9797
deployment_name=DEPLOYMENT_NAME, build_id=build_id
9898
)
9999

100-
# Wait for the worker to appear
101100
while True:
102101
try:
103102
describe_request = wsv1.DescribeWorkerDeploymentRequest(
@@ -108,7 +107,6 @@ async def wait_for_worker_and_make_current(client: Client, build_id: str) -> Non
108107
describe_request
109108
)
110109

111-
# Check if our version is present in the version summaries
112110
for version_summary in response.worker_deployment_info.version_summaries:
113111
if (
114112
version_summary.deployment_version.deployment_name

0 commit comments

Comments
 (0)