René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Error for template code in Task Group API (with python 3.12)","articleBody":"```python\n# Stream all results from the group\nasync def get_all_results(client: parallel.AsyncParallel, taskgroup_id: str):\n    results = []\n\n    path = f\"/v1beta/tasks/groups/{taskgroup_id}/runs\"\n    path += \"?include_input=true\u0026include_output=true\"\n\n    result_stream = await client.get(\n        path=path,\n        cast_to=TaskRunEvent | ErrorResponse | None,\n        stream=True,\n        stream_cls=parallel.AsyncStream[TaskRunEvent | ErrorResponse],\n    )\n\n    async for event in result_stream:\n        if isinstance(event, TaskRunEvent) and event.output:\n            company_input = CompanyInput.model_validate(event.input.input)\n            company_output = CompanyOutput.model_validate(event.output.content)\n\n            results.append(\n                {\n                    \"company\": company_input.company_name,\n                    \"insights\": company_output.key_insights,\n                    \"market_position\": company_output.market_position,\n                }\n            )\n\n    return results\n\nresults = await get_all_results(client, taskgroup_id)\nprint(f\"Processed {len(results)} companies successfully\")\n```\n\nThis code doesnt work for python 3.12 as this line `cast_to=TaskRunEvent | ErrorResponse | None` use weak ref type so it raised Error as `TypeError: cannot create weak reference to 'types.UnionType' object`. \n\n\nCode fix: using strong UNION type to resolve this issue\n\n```python\nfrom typing import Union\n\nasync def get_all_results(client: parallel.AsyncParallel, taskgroup_id: str):\n    results = []\n\n    path = f\"/v1beta/tasks/groups/{taskgroup_id}/runs\"\n    path += \"?include_input=true\u0026include_output=true\"\n\n    result_stream = await client.get(\n        path=path,\n        cast_to=Union[TaskRunEvent, ErrorResponse, None],  # Use typing.Union instead of |\n        stream=True,\n        stream_cls=parallel.AsyncStream[Union[TaskRunEvent, ErrorResponse]],  # Also update this\n    )\n\n    async for event in result_stream:\n          if isinstance(event, TaskRunEvent) and event.output:\n              company_input = CompanyInput.model_validate(event.input.input)\n              company_output = CompanyOutput.model_validate(event.output.content)\n\n              results.append(\n                  {\n                      \"vendor_gold_key\": company_input.vendor_gold_key,\n                      \"vendor_name\": company_input.company_name,\n                      \"tax_code\": company_input.tax_code,\n                      \"country_code\": company_input.country_code,\n                      \"research_summary\": company_output.company_research_summary,\n                      \"is_exclusion\": company_output.is_exclusion,\n                  }\n              )\n          return results\n\nresults = await get_all_results(client, taskgroup_id)\nprint(f\"Processed {len(results)} companies successfully\")\n```","author":{"url":"https://github.com/Hazzng","@type":"Person","name":"Hazzng"},"datePublished":"2025-11-18T00:42:45.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":0},"url":"https://github.com/20/parallel-sdk-python/issues/20"}