Upload files to "expected_workflows"
This commit is contained in:
parent
2c55ab4ad8
commit
6eaac4cefb
@ -6,7 +6,6 @@ import json
|
||||
import datetime
|
||||
import re
|
||||
import jmespath
|
||||
from temporalio.workflow import sleep
|
||||
|
||||
# Configure logging
|
||||
logging.basicConfig(level=logging.INFO,
|
||||
@ -17,7 +16,6 @@ logger = logging.getLogger(__name__)
|
||||
class test_repo_test_branch:
|
||||
@temporalio.workflow.run
|
||||
async def run(self, root_inputs: Dict[str, Any]) -> Dict[str, Any]:
|
||||
await sleep(0)
|
||||
workflow_info = temporalio.workflow.info()
|
||||
workflow_output: Dict[str, Any] = {
|
||||
"workflow_id": workflow_info.workflow_id,
|
||||
|
||||
@ -6,7 +6,6 @@ import json
|
||||
import datetime
|
||||
import re
|
||||
import jmespath
|
||||
from temporalio.workflow import sleep
|
||||
|
||||
# Configure logging
|
||||
logging.basicConfig(level=logging.INFO,
|
||||
@ -17,7 +16,6 @@ logger = logging.getLogger(__name__)
|
||||
class test_repo_test_branch:
|
||||
@temporalio.workflow.run
|
||||
async def run(self, root_inputs: Dict[str, Any]) -> Dict[str, Any]:
|
||||
await sleep(0)
|
||||
workflow_info = temporalio.workflow.info()
|
||||
workflow_output: Dict[str, Any] = {
|
||||
"workflow_id": workflow_info.workflow_id,
|
||||
|
||||
@ -6,7 +6,6 @@ import json
|
||||
import datetime
|
||||
import re
|
||||
import jmespath
|
||||
from temporalio.workflow import sleep
|
||||
|
||||
# Configure logging
|
||||
logging.basicConfig(level=logging.INFO,
|
||||
@ -17,7 +16,6 @@ logger = logging.getLogger(__name__)
|
||||
class test_repo_test_branch:
|
||||
@temporalio.workflow.run
|
||||
async def run(self, root_inputs: Dict[str, Any]) -> Dict[str, Any]:
|
||||
await sleep(0)
|
||||
workflow_info = temporalio.workflow.info()
|
||||
workflow_output: Dict[str, Any] = {
|
||||
"workflow_id": workflow_info.workflow_id,
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user