Skip to content

Many Small Workflows system test #1398

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
Jun 2, 2023
Merged

Many Small Workflows system test #1398

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
321 changes: 321 additions & 0 deletions examples/system-tests/Many_Small_Workflows.ipynb
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,321 @@
{
"cells": [
{
"cell_type": "code",
"execution_count": 3,
"id": "6ac2a668",
"metadata": {},
"outputs": [],
"source": [
"import aqueduct as aq\n",
"from aqueduct.constants.enums import ArtifactType\n",
"\n",
"client = aq.Client(api_key=\"\", aqueduct_address=\"\")\n",
"aq.global_config({\"lazy\": True})"
]
},
{
"cell_type": "code",
"execution_count": 5,
"id": "493da5de",
"metadata": {},
"outputs": [],
"source": [
"snowflake_warehouse = client.resource('snowflake_resource')\n",
"hotel_reviews = snowflake_warehouse.sql('SELECT * FROM hotel_reviews;')"
]
},
{
"cell_type": "code",
"execution_count": 7,
"id": "82b5186b",
"metadata": {},
"outputs": [],
"source": [
"@aq.op(requirements=[])\n",
"def sample_function(df):\n",
" df[\"positivity\"] = 123\n",
" return df\n",
"\n",
"output_df = sample_function(hotel_reviews)"
]
},
{
"cell_type": "code",
"execution_count": 10,
"id": "6eb4caad",
"metadata": {},
"outputs": [
{
"name": "stdout",
"output_type": "stream",
"text": [
"Url: http://3.130.165.53:8080/workflow/344777ff-d2ea-4c53-82b3-4c4ef0de1283\n",
"Url: http://3.130.165.53:8080/workflow/019f67a3-33e1-450b-96be-8020a1a32501\n",
"Url: http://3.130.165.53:8080/workflow/0f390ef5-d5c6-4b72-858f-cbcb9d1dc581\n",
"Url: http://3.130.165.53:8080/workflow/b42d5e2f-a5bd-477b-99e2-241bca02a9e7\n",
"Url: http://3.130.165.53:8080/workflow/431169fc-68ff-478a-ab38-7197c8909de9\n",
"Url: http://3.130.165.53:8080/workflow/5c3617eb-9c8d-4f6d-ba24-e7a2537f98a9\n",
"Url: http://3.130.165.53:8080/workflow/3a60825f-850f-49cd-888f-fdfff9b1d7cf\n",
"Url: http://3.130.165.53:8080/workflow/9bdb57f3-6ed9-4957-975e-7c95e8f1d93d\n",
"Url: http://3.130.165.53:8080/workflow/0fc445a4-3cf5-465c-81f7-6ac6892ba3ce\n",
"Url: http://3.130.165.53:8080/workflow/385aa120-11ad-4172-9fff-2b238e862eea\n",
"Url: http://3.130.165.53:8080/workflow/dfa9dc88-30d0-43bf-91bc-774d3962c21e\n",
"Url: http://3.130.165.53:8080/workflow/050d5a06-6547-4647-83a9-81ed6230d69f\n",
"Url: http://3.130.165.53:8080/workflow/ad668c60-46b9-400f-b574-794445403fbc\n",
"Url: http://3.130.165.53:8080/workflow/4dd0011f-5478-4a7c-890f-d95d05265d49\n",
"Url: http://3.130.165.53:8080/workflow/e3cef694-a8d0-42e0-a5f0-e2fbfa122103\n",
"Url: http://3.130.165.53:8080/workflow/b5027c30-c506-4545-96ea-3a9ebcd1a5fd\n",
"Url: http://3.130.165.53:8080/workflow/19d4d3c1-9c6c-4bd7-a415-d48ce227d83c\n",
"Url: http://3.130.165.53:8080/workflow/27228e51-f82c-488e-9d83-85c8c695caec\n",
"Url: http://3.130.165.53:8080/workflow/d7c6c0e5-2119-4a7e-b864-1bd173f4eca0\n",
"Url: http://3.130.165.53:8080/workflow/921493df-a8c2-4dc1-be4b-c36263f8a814\n",
"Url: http://3.130.165.53:8080/workflow/a1fb0f87-3822-4bed-9812-a2f2fb789c82\n",
"Url: http://3.130.165.53:8080/workflow/5e2f6f24-5135-4c19-968a-0b61aa5e9a09\n",
"Url: http://3.130.165.53:8080/workflow/cc8c86b1-2232-401b-aa93-b5f6ad4cc43a\n",
"Url: http://3.130.165.53:8080/workflow/f4254d0f-7c5d-457e-80c7-8851eec7f464\n",
"Url: http://3.130.165.53:8080/workflow/611cfc71-5677-46f2-be8f-7a91799d02ad\n",
"Url: http://3.130.165.53:8080/workflow/8cfd8089-9956-489c-ba4e-c65ac80c6004\n",
"Url: http://3.130.165.53:8080/workflow/109a627a-709e-4b20-ac56-2f59c4da3763\n",
"Url: http://3.130.165.53:8080/workflow/76dbc344-bbc4-4fd0-ba40-ebe3d3d40c96\n",
"Url: http://3.130.165.53:8080/workflow/23116153-7cb8-453e-82a3-2c55703e8e5d\n",
"Url: http://3.130.165.53:8080/workflow/6630d827-728b-4aa1-bf1a-51e7f686595a\n",
"Url: http://3.130.165.53:8080/workflow/877cd7f1-5616-46e9-b0a7-f435fa83d028\n",
"Url: http://3.130.165.53:8080/workflow/c26eac81-2702-4208-9013-8c2b5806dd1d\n",
"Url: http://3.130.165.53:8080/workflow/9b56bb9e-c776-4567-9e81-c73cc5cf487c\n",
"Url: http://3.130.165.53:8080/workflow/d6ad0daf-e491-43b3-ab92-9255b09fad94\n",
"Url: http://3.130.165.53:8080/workflow/4435f02b-3de3-4fb3-bfba-55cc9ec6f39e\n",
"Url: http://3.130.165.53:8080/workflow/4918cd90-85de-4bab-9ef9-14120f8cdacd\n",
"Url: http://3.130.165.53:8080/workflow/09fc38ae-e76a-4d84-b9af-3c7caa82fb54\n",
"Url: http://3.130.165.53:8080/workflow/b7281f93-2f0d-4285-adfb-9dcaba48b686\n",
"Url: http://3.130.165.53:8080/workflow/21526137-0247-40a8-a174-8caa15ef6b5d\n",
"Url: http://3.130.165.53:8080/workflow/c50a4220-bdc6-443b-a5e7-48a116e8618e\n",
"Url: http://3.130.165.53:8080/workflow/cdd75643-c321-426d-98ed-51e2c8e45f15\n",
"Url: http://3.130.165.53:8080/workflow/2d68a2d1-f77a-4b7f-9c30-433b46b623ef\n",
"Url: http://3.130.165.53:8080/workflow/c8ca16ee-b5f9-46ea-a1db-4113b9501698\n",
"Url: http://3.130.165.53:8080/workflow/f0bbf389-ba58-484f-9506-590ffdd41127\n",
"Url: http://3.130.165.53:8080/workflow/80e0b99a-29a4-4c56-8a6f-3cfc1514831b\n",
"Url: http://3.130.165.53:8080/workflow/4fc26f74-385c-41d8-8e7a-15740c5a131c\n",
"Url: http://3.130.165.53:8080/workflow/5340ef9f-f8a2-486b-a881-e30afdfebe4c\n",
"Url: http://3.130.165.53:8080/workflow/ec20c719-13d0-4059-ba6c-22ec5e1b98dc\n",
"Url: http://3.130.165.53:8080/workflow/8e68c42f-a9a0-4908-a311-3eb6f5826027\n",
"Url: http://3.130.165.53:8080/workflow/604516e1-049d-4a9d-9027-2940be8c7622\n",
"Url: http://3.130.165.53:8080/workflow/f47bddb2-879f-4dae-a1ee-a2f044702088\n",
"Url: http://3.130.165.53:8080/workflow/300a61a4-0473-492e-9a1f-fbb58d81a6e1\n",
"Url: http://3.130.165.53:8080/workflow/b1741a38-f4d6-4331-bc7f-ecdfd9f17220\n",
"Url: http://3.130.165.53:8080/workflow/829beca5-2e50-4fd4-abe5-582dff4495ca\n",
"Url: http://3.130.165.53:8080/workflow/7022a40b-f15a-4c7e-9333-210cd4a4e842\n",
"Url: http://3.130.165.53:8080/workflow/0072fa00-fe4c-4604-9d47-e3a8f7a3930d\n",
"Url: http://3.130.165.53:8080/workflow/c6574d09-7ff2-4479-8660-33d13c64002b\n",
"Url: http://3.130.165.53:8080/workflow/64f7f8d8-8803-4018-bc15-0a165ca7f7c3\n",
"Url: http://3.130.165.53:8080/workflow/3912518d-ec46-42c5-8bf4-1d5692065a7f\n",
"Url: http://3.130.165.53:8080/workflow/c5d79886-8403-480d-985b-eb0fac88b3fe\n",
"Url: http://3.130.165.53:8080/workflow/b19fbb26-bc35-4e3b-936a-bf8aebdc9736\n",
"Url: http://3.130.165.53:8080/workflow/f385e2f1-4d8f-4d49-8f8c-ec231df91adc\n",
"Url: http://3.130.165.53:8080/workflow/68352738-2005-455e-b221-add761a1d88c\n",
"Url: http://3.130.165.53:8080/workflow/2f0f31d1-bce6-4043-8b0d-57b739244493\n",
"Url: http://3.130.165.53:8080/workflow/0b7901fe-87f5-4042-a8ed-ad3e5b144e2b\n",
"Url: http://3.130.165.53:8080/workflow/180bcd9f-8dae-43bb-92ba-e06604279dd6\n",
"Url: http://3.130.165.53:8080/workflow/0038b1b4-8414-4705-a7a2-a66a315a7362\n",
"Url: http://3.130.165.53:8080/workflow/2cda6475-9898-4b0b-9f95-5707a830befb\n",
"Url: http://3.130.165.53:8080/workflow/401fd0ff-ff56-408b-839e-583f5750fe75\n",
"Url: http://3.130.165.53:8080/workflow/fc3578a3-6dac-4986-b087-7ae8d3dc39f7\n",
"Url: http://3.130.165.53:8080/workflow/07ff198c-39e3-4b68-98be-4d396ad177be\n",
"Url: http://3.130.165.53:8080/workflow/c5fdbe50-572c-4dc1-aa25-649d63dcc468\n",
"Url: http://3.130.165.53:8080/workflow/28cf98f5-99f4-4328-b714-a5a7da0621ee\n",
"Url: http://3.130.165.53:8080/workflow/c9039968-5a90-440f-a374-2394b87d5e4c\n",
"Url: http://3.130.165.53:8080/workflow/0d2c516d-cd3a-4cdd-b24a-70fac31b1b8b\n",
"Url: http://3.130.165.53:8080/workflow/db2a7b2e-03b1-4802-82df-a05f9852e6c3\n",
"Url: http://3.130.165.53:8080/workflow/f4f5f856-20ce-4760-bcc6-96e228aa0c91\n",
"Url: http://3.130.165.53:8080/workflow/e22283f7-477b-4baf-9f85-883d7615b670\n",
"Url: http://3.130.165.53:8080/workflow/a6c5d241-d182-4e98-b6e5-8f6874485ed4\n",
"Url: http://3.130.165.53:8080/workflow/1c83ca77-6528-45e7-b520-18c362adee39\n",
"Url: http://3.130.165.53:8080/workflow/ce9be6c9-1e1a-43bf-851c-bc73af90911f\n",
"Url: http://3.130.165.53:8080/workflow/cebf5485-adc5-4587-83f2-f64b565a6488\n",
"Url: http://3.130.165.53:8080/workflow/a1394621-7f5c-417f-a3c6-4bbec9f546ee\n",
"Url: http://3.130.165.53:8080/workflow/b22c32a6-a2d8-4862-b48d-66b881982415\n",
"Url: http://3.130.165.53:8080/workflow/a3779235-6a82-4f02-a44d-cd9d69658e8f\n",
"Url: http://3.130.165.53:8080/workflow/3d202b90-b1bd-4925-95bb-a5a485dd180f\n",
"Url: http://3.130.165.53:8080/workflow/86a26c10-e7f4-4764-85ea-62a02f570982\n",
"Url: http://3.130.165.53:8080/workflow/5eb14f89-ec6d-4b59-a624-4c46e2b7a525\n",
"Url: http://3.130.165.53:8080/workflow/5cfee256-5adf-4840-9465-cbe08733eb5c\n",
"Url: http://3.130.165.53:8080/workflow/e3068292-30da-4eb5-b2db-fd80414987d8\n",
"Url: http://3.130.165.53:8080/workflow/40265a70-6c2c-46f3-83c8-19f77d03febe\n",
"Url: http://3.130.165.53:8080/workflow/32da9df6-5de7-4e23-a5ed-1d694bb43984\n",
"Url: http://3.130.165.53:8080/workflow/161069be-4a90-44e2-8071-dd00809d1e1e\n",
"Url: http://3.130.165.53:8080/workflow/cbf1e26e-4660-4137-a2b1-e50e9a4f8827\n",
"Url: http://3.130.165.53:8080/workflow/ad2021db-7444-4205-bb72-0f9c0b5c524c\n",
"Url: http://3.130.165.53:8080/workflow/5756953b-f567-4f82-a6c2-f8aeffe0b5b2\n",
"Url: http://3.130.165.53:8080/workflow/1374b714-108f-40cb-9ffb-47cda0d6e917\n",
"Url: http://3.130.165.53:8080/workflow/9c8d8e54-a8df-4d7e-bbe5-2bbc043b6fc6\n",
"Url: http://3.130.165.53:8080/workflow/883aca41-a570-4eb1-9ec1-a2b9dcc03d10\n",
"Url: http://3.130.165.53:8080/workflow/33066b44-0bd4-4229-b305-203ecb0afad1\n"
]
}
],
"source": [
"# snowflake_warehouse.save(generated_df, table_name=\"large_hotel_reviews\", update_mode=\"replace\")\n",
"flow_map = {}\n",
"\n",
"for i in range(100):\n",
" name = \"many_small_workflows_\"+str(i)\n",
" flow_obj = client.publish_flow(\n",
" name,\n",
" \"many workflows at once\",\n",
" schedule=\"*/10 * * * *\",\n",
" artifacts=[output_df],\n",
" )\n",
" flow_map[name] = flow_obj"
]
},
{
"cell_type": "code",
"execution_count": 11,
"id": "3c9269a9",
"metadata": {},
"outputs": [
{
"data": {
"text/plain": [
"{'many_small_workflows_0': <aqueduct.flow.Flow at 0x7fedbfbd4e80>,\n",
" 'many_small_workflows_1': <aqueduct.flow.Flow at 0x7fedc0200d30>,\n",
" 'many_small_workflows_2': <aqueduct.flow.Flow at 0x7fedbfbf2550>,\n",
" 'many_small_workflows_3': <aqueduct.flow.Flow at 0x7fedbfbf2100>,\n",
" 'many_small_workflows_4': <aqueduct.flow.Flow at 0x7fedbfbf2940>,\n",
" 'many_small_workflows_5': <aqueduct.flow.Flow at 0x7fedbfbe2e80>,\n",
" 'many_small_workflows_6': <aqueduct.flow.Flow at 0x7fedc0206430>,\n",
" 'many_small_workflows_7': <aqueduct.flow.Flow at 0x7fedbfbf7c10>,\n",
" 'many_small_workflows_8': <aqueduct.flow.Flow at 0x7fedbfbf7a30>,\n",
" 'many_small_workflows_9': <aqueduct.flow.Flow at 0x7fedbf5cffa0>,\n",
" 'many_small_workflows_10': <aqueduct.flow.Flow at 0x7fedbf5cf310>,\n",
" 'many_small_workflows_11': <aqueduct.flow.Flow at 0x7fedbf5cf3a0>,\n",
" 'many_small_workflows_12': <aqueduct.flow.Flow at 0x7fedbf5ef7f0>,\n",
" 'many_small_workflows_13': <aqueduct.flow.Flow at 0x7fedbf5ef940>,\n",
" 'many_small_workflows_14': <aqueduct.flow.Flow at 0x7fedbf5ef820>,\n",
" 'many_small_workflows_15': <aqueduct.flow.Flow at 0x7fedbf6051f0>,\n",
" 'many_small_workflows_16': <aqueduct.flow.Flow at 0x7fedbf603ee0>,\n",
" 'many_small_workflows_17': <aqueduct.flow.Flow at 0x7fedbf608820>,\n",
" 'many_small_workflows_18': <aqueduct.flow.Flow at 0x7fedbfbd8100>,\n",
" 'many_small_workflows_19': <aqueduct.flow.Flow at 0x7fedbfbd8a30>,\n",
" 'many_small_workflows_20': <aqueduct.flow.Flow at 0x7fedbfbd8310>,\n",
" 'many_small_workflows_21': <aqueduct.flow.Flow at 0x7fedbfbeb760>,\n",
" 'many_small_workflows_22': <aqueduct.flow.Flow at 0x7fedbfbeb7f0>,\n",
" 'many_small_workflows_23': <aqueduct.flow.Flow at 0x7fedbfbd53d0>,\n",
" 'many_small_workflows_24': <aqueduct.flow.Flow at 0x7fedbfc7bfd0>,\n",
" 'many_small_workflows_25': <aqueduct.flow.Flow at 0x7fedbfc7bd60>,\n",
" 'many_small_workflows_26': <aqueduct.flow.Flow at 0x7fedbfc7bdc0>,\n",
" 'many_small_workflows_27': <aqueduct.flow.Flow at 0x7fedbfc7bf10>,\n",
" 'many_small_workflows_28': <aqueduct.flow.Flow at 0x7fedbfc7b8b0>,\n",
" 'many_small_workflows_29': <aqueduct.flow.Flow at 0x7fedbfc7bb80>,\n",
" 'many_small_workflows_30': <aqueduct.flow.Flow at 0x7fedbfc7b970>,\n",
" 'many_small_workflows_31': <aqueduct.flow.Flow at 0x7fedbfc7bac0>,\n",
" 'many_small_workflows_32': <aqueduct.flow.Flow at 0x7fedbfc7ba90>,\n",
" 'many_small_workflows_33': <aqueduct.flow.Flow at 0x7fedbfc7b370>,\n",
" 'many_small_workflows_34': <aqueduct.flow.Flow at 0x7fedbfc7b880>,\n",
" 'many_small_workflows_35': <aqueduct.flow.Flow at 0x7fedbfc7bb50>,\n",
" 'many_small_workflows_36': <aqueduct.flow.Flow at 0x7fedbfbd5760>,\n",
" 'many_small_workflows_37': <aqueduct.flow.Flow at 0x7fedbfc7b580>,\n",
" 'many_small_workflows_38': <aqueduct.flow.Flow at 0x7fedbfc7bbb0>,\n",
" 'many_small_workflows_39': <aqueduct.flow.Flow at 0x7fedbfc7bd90>,\n",
" 'many_small_workflows_40': <aqueduct.flow.Flow at 0x7fedbfc7bcd0>,\n",
" 'many_small_workflows_41': <aqueduct.flow.Flow at 0x7fedbfbd89a0>,\n",
" 'many_small_workflows_42': <aqueduct.flow.Flow at 0x7fedbfc7c700>,\n",
" 'many_small_workflows_43': <aqueduct.flow.Flow at 0x7fedbfc7bc10>,\n",
" 'many_small_workflows_44': <aqueduct.flow.Flow at 0x7fedbfc7ca30>,\n",
" 'many_small_workflows_45': <aqueduct.flow.Flow at 0x7fedbfc7c730>,\n",
" 'many_small_workflows_46': <aqueduct.flow.Flow at 0x7fedbfc7c970>,\n",
" 'many_small_workflows_47': <aqueduct.flow.Flow at 0x7fedbfc7c0a0>,\n",
" 'many_small_workflows_48': <aqueduct.flow.Flow at 0x7fedbf5cf490>,\n",
" 'many_small_workflows_49': <aqueduct.flow.Flow at 0x7fedbfc7c9d0>,\n",
" 'many_small_workflows_50': <aqueduct.flow.Flow at 0x7fedbfc7c760>,\n",
" 'many_small_workflows_51': <aqueduct.flow.Flow at 0x7fedbfc7cd30>,\n",
" 'many_small_workflows_52': <aqueduct.flow.Flow at 0x7fedbfc7bd00>,\n",
" 'many_small_workflows_53': <aqueduct.flow.Flow at 0x7fedbfc7c8e0>,\n",
" 'many_small_workflows_54': <aqueduct.flow.Flow at 0x7fedbfc7ce50>,\n",
" 'many_small_workflows_55': <aqueduct.flow.Flow at 0x7fedbfc7c670>,\n",
" 'many_small_workflows_56': <aqueduct.flow.Flow at 0x7fedbfc7c4f0>,\n",
" 'many_small_workflows_57': <aqueduct.flow.Flow at 0x7fedbfc7c3a0>,\n",
" 'many_small_workflows_58': <aqueduct.flow.Flow at 0x7fedbfc7ccd0>,\n",
" 'many_small_workflows_59': <aqueduct.flow.Flow at 0x7fedbfc7c250>,\n",
" 'many_small_workflows_60': <aqueduct.flow.Flow at 0x7fedbfc7cd60>,\n",
" 'many_small_workflows_61': <aqueduct.flow.Flow at 0x7fedbfc7c6a0>,\n",
" 'many_small_workflows_62': <aqueduct.flow.Flow at 0x7fedbfc7c6d0>,\n",
" 'many_small_workflows_63': <aqueduct.flow.Flow at 0x7fedbfc7caf0>,\n",
" 'many_small_workflows_64': <aqueduct.flow.Flow at 0x7fedbfc7c520>,\n",
" 'many_small_workflows_65': <aqueduct.flow.Flow at 0x7fedbfc7c880>,\n",
" 'many_small_workflows_66': <aqueduct.flow.Flow at 0x7fedbfc7cdf0>,\n",
" 'many_small_workflows_67': <aqueduct.flow.Flow at 0x7fedbfc7c2b0>,\n",
" 'many_small_workflows_68': <aqueduct.flow.Flow at 0x7fedbfc7c430>,\n",
" 'many_small_workflows_69': <aqueduct.flow.Flow at 0x7fedbfc7cee0>,\n",
" 'many_small_workflows_70': <aqueduct.flow.Flow at 0x7fedbfc7cfa0>,\n",
" 'many_small_workflows_71': <aqueduct.flow.Flow at 0x7fedbfc7c1c0>,\n",
" 'many_small_workflows_72': <aqueduct.flow.Flow at 0x7fedbfc7c3d0>,\n",
" 'many_small_workflows_73': <aqueduct.flow.Flow at 0x7fedbfc7ca90>,\n",
" 'many_small_workflows_74': <aqueduct.flow.Flow at 0x7fedbfc7c9a0>,\n",
" 'many_small_workflows_75': <aqueduct.flow.Flow at 0x7fedbfc7c460>,\n",
" 'many_small_workflows_76': <aqueduct.flow.Flow at 0x7fedbfc7c190>,\n",
" 'many_small_workflows_77': <aqueduct.flow.Flow at 0x7fedbfc7ce80>,\n",
" 'many_small_workflows_78': <aqueduct.flow.Flow at 0x7fedbfc7c280>,\n",
" 'many_small_workflows_79': <aqueduct.flow.Flow at 0x7fedbfc7cac0>,\n",
" 'many_small_workflows_80': <aqueduct.flow.Flow at 0x7fedbfbd54c0>,\n",
" 'many_small_workflows_81': <aqueduct.flow.Flow at 0x7fedbfc7c610>,\n",
" 'many_small_workflows_82': <aqueduct.flow.Flow at 0x7fedbfc7c340>,\n",
" 'many_small_workflows_83': <aqueduct.flow.Flow at 0x7fedbfc7cbb0>,\n",
" 'many_small_workflows_84': <aqueduct.flow.Flow at 0x7fedbfc7c640>,\n",
" 'many_small_workflows_85': <aqueduct.flow.Flow at 0x7fedbfc4ea00>,\n",
" 'many_small_workflows_86': <aqueduct.flow.Flow at 0x7fedbfc4e4c0>,\n",
" 'many_small_workflows_87': <aqueduct.flow.Flow at 0x7fedbfc4e730>,\n",
" 'many_small_workflows_88': <aqueduct.flow.Flow at 0x7fedbfc4ec10>,\n",
" 'many_small_workflows_89': <aqueduct.flow.Flow at 0x7fedbfc4eb20>,\n",
" 'many_small_workflows_90': <aqueduct.flow.Flow at 0x7fedbfc4e760>,\n",
" 'many_small_workflows_91': <aqueduct.flow.Flow at 0x7fedbfc4e670>,\n",
" 'many_small_workflows_92': <aqueduct.flow.Flow at 0x7fedbf60b9a0>,\n",
" 'many_small_workflows_93': <aqueduct.flow.Flow at 0x7fedbfc4e790>,\n",
" 'many_small_workflows_94': <aqueduct.flow.Flow at 0x7fedbfc4ee20>,\n",
" 'many_small_workflows_95': <aqueduct.flow.Flow at 0x7fedbfc4ed00>,\n",
" 'many_small_workflows_96': <aqueduct.flow.Flow at 0x7fedbfbd8e50>,\n",
" 'many_small_workflows_97': <aqueduct.flow.Flow at 0x7fedbfc4e8b0>,\n",
" 'many_small_workflows_98': <aqueduct.flow.Flow at 0x7fedbfc4e820>,\n",
" 'many_small_workflows_99': <aqueduct.flow.Flow at 0x7fedbfc4e700>}"
]
},
"execution_count": 11,
"metadata": {},
"output_type": "execute_result"
}
],
"source": [
"flow_map"
]
},
{
"cell_type": "code",
"execution_count": null,
"id": "fe4dfe66",
"metadata": {},
"outputs": [],
"source": []
}
],
"metadata": {
"kernelspec": {
"display_name": "39pytest",
"language": "python",
"name": "39pytest"
},
"language_info": {
"codemirror_mode": {
"name": "ipython",
"version": 3
},
"file_extension": ".py",
"mimetype": "text/x-python",
"name": "python",
"nbconvert_exporter": "python",
"pygments_lexer": "ipython3",
"version": "3.8.8"
}
},
"nbformat": 4,
"nbformat_minor": 5
}