Skip to content

Commit

Permalink
Many Small Workflows system test (#1398)
Browse files Browse the repository at this point in the history
  • Loading branch information
@hsubbaraj-spiral
hsubbaraj-spiral authored Jun 2, 2023
1 parent 7d95f26 commit 79f9259
Showing 1 changed file with 321 additions and 0 deletions.
321 changes: 321 additions & 0 deletions examples/system-tests/Many_Small_Workflows.ipynb
View file
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
}

0 comments on commit 79f9259

Please sign in to comment.