Initial activity worker example (#1)

Author: cretz

.github/workflows/ci.yml

@@ -0,0 +1,31 @@
+name: Continuous Integration
+on: # rebuild any PRs and main branch changes
+  pull_request:
+  push:
+    branches:
+      - main
+      - "releases/*"
+
+jobs:
+  # Build and test the project
+  build-lint-test:
+    strategy:
+      fail-fast: true
+      matrix:
+        python: ["3.7", "3.10"]
+        os: [ubuntu-latest, macos-latest, windows-latest]
+    runs-on: ${{ matrix.os }}
+    steps:
+      - name: Print build information
+        run: "echo head_ref: ${{ github.head_ref }}, ref: ${{ github.ref }}, os: ${{ matrix.os }}, python: ${{ matrix.python }}"
+      - uses: actions/checkout@v2
+        with:
+          submodules: recursive
+      - uses: actions/setup-python@v1
+        with:
+          python-version: ${{ matrix.python }}
+      - run: python -m pip install --upgrade wheel poetry poethepoet
+      - run: poetry install
+      - run: poe lint
+      - run: poe test -s -o log_cli_level=DEBUG
+

.gitignore

@@ -0,0 +1,2 @@
+.venv
+__pycache__

LICENSE

@@ -0,0 +1,21 @@
+The MIT License
+
+Copyright (c) 2022 Temporal Technologies Inc.  All rights reserved.
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

README.md

@@ -0,0 +1,28 @@
+# Temporal Python SDK Samples
+
+This is the set of Python samples for the [Python SDK](https://github.com/temporalio/sdk-python).
+
+**UNDER DEVELOPMENT**
+
+The Python SDK is under development. There are no compatibility guarantees nor proper documentation pages at this time.
+
+## Usage
+
+Prerequisites:
+
+* Python >= 3.7
+* [Poetry](https://python-poetry.org)
+
+With this repository cloned, run the following at the root of the directory:
+
+    poetry install --no-root
+
+That loads all dependencies. Then to run a sample, usually you just run it in Python:
+
+    poetry run python script_name.py
+
+See each sample's directory for specific instructions.
+
+## Samples
+
+* [Activity Worker](activity_worker) - Use Python activities from a workflow in another language

activity_worker/README.md

@@ -0,0 +1,13 @@
+# Activity Worker
+
+This sample shows a Go workflow calling a Python activity.
+
+First run the Go workflow worker by running this in the `go_workflow` directory in a separate terminal:
+
+    go run .
+
+Then in another terminal, run the sample from this directory:
+
+    poetry run python activity_worker.py
+
+The Python code will invoke the Go workflow which will execute the Python activity and return.

activity_worker/activity_worker.py

@@ -0,0 +1,37 @@
+import asyncio
+import random
+import string
+
+from temporalio.client import Client
+from temporalio.worker import Worker
+
+task_queue = "say-hello-task-queue"
+workflow_name = "say-hello-workflow"
+activity_name = "say-hello-activity"
+
+
+async def say_hello_activity(name: str) -> str:
+    return f"Hello, {name}!"
+
+
+async def main():
+    # Create client to localhost on default namespace
+    client = await Client.connect("http://localhost:7233")
+
+    # Run activity worker
+    async with Worker(
+        client, task_queue=task_queue, activities={activity_name: say_hello_activity}
+    ):
+        # Run the Go workflow
+        workflow_id = "".join(
+            random.choices(string.ascii_uppercase + string.digits, k=30)
+        )
+        result = await client.execute_workflow(
+            workflow_name, "Temporal", id=workflow_id, task_queue=task_queue
+        )
+        # Print out "Hello, Temporal!"
+        print(result)
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

activity_worker/go_workflow/go.mod

@@ -0,0 +1,32 @@
+module github.com/temporalio/samples-python/activity_worker/go_workflow
+
+go 1.17
+
+require go.temporal.io/sdk v1.14.0
+
+require (
+	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/facebookgo/clock v0.0.0-20150410010913-600d898af40a // indirect
+	github.com/gogo/googleapis v1.4.1 // indirect
+	github.com/gogo/protobuf v1.3.2 // indirect
+	github.com/gogo/status v1.1.0 // indirect
+	github.com/golang/mock v1.6.0 // indirect
+	github.com/golang/protobuf v1.5.2 // indirect
+	github.com/google/uuid v1.3.0 // indirect
+	github.com/grpc-ecosystem/go-grpc-middleware v1.3.0 // indirect
+	github.com/pborman/uuid v1.2.1 // indirect
+	github.com/pmezard/go-difflib v1.0.0 // indirect
+	github.com/robfig/cron v1.2.0 // indirect
+	github.com/stretchr/objx v0.3.0 // indirect
+	github.com/stretchr/testify v1.7.0 // indirect
+	go.temporal.io/api v1.7.1-0.20220223032354-6e6fe738916a // indirect
+	go.uber.org/atomic v1.9.0 // indirect
+	golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd // indirect
+	golang.org/x/sys v0.0.0-20220222200937-f2425489ef4c // indirect
+	golang.org/x/text v0.3.7 // indirect
+	golang.org/x/time v0.0.0-20210723032227-1f47c861a9ac // indirect
+	google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf // indirect
+	google.golang.org/grpc v1.44.0 // indirect
+	google.golang.org/protobuf v1.27.1 // indirect
+	gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b // indirect
+)