+{"nbformat":4,"nbformat_minor":0,"metadata":{"colab":{"provenance":[{"file_id":"14zrnkNGyi3OGn5VG2ORboomI5AMEMHzm","timestamp":1689128534406}]},"kernelspec":{"name":"python3","display_name":"Python 3"},"language_info":{"name":"python"}},"cells":[{"cell_type":"code","execution_count":1,"metadata":{"colab":{"base_uri":"https://localhost:8080/"},"id":"CFMpQQ8hhivp","executionInfo":{"status":"ok","timestamp":1689608690745,"user_tz":420,"elapsed":11270,"user":{"displayName":"Elijah Spina","userId":"09538733801989465977"}},"outputId":"9d015231-2efd-447e-f1f8-b83ce1294785"},"outputs":[{"output_type":"stream","name":"stdout","text":["Collecting PlexLabExchange\n"," Downloading PlexLabExchange-0.8.18-py3-none-manylinux2014_x86_64.whl (26.9 MB)\n","\u001b[2K \u001b[90m━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\u001b[0m \u001b[32m26.9/26.9 MB\u001b[0m \u001b[31m41.7 MB/s\u001b[0m eta \u001b[36m0:00:00\u001b[0m\n","\u001b[?25hInstalling collected packages: PlexLabExchange\n","Successfully installed PlexLabExchange-0.8.18\n","Requirement already satisfied: requests in /usr/local/lib/python3.10/dist-packages (2.27.1)\n","Requirement already satisfied: urllib3<1.27,>=1.21.1 in /usr/local/lib/python3.10/dist-packages (from requests) (1.26.16)\n","Requirement already satisfied: certifi>=2017.4.17 in /usr/local/lib/python3.10/dist-packages (from requests) (2023.5.7)\n","Requirement already satisfied: charset-normalizer~=2.0.0 in /usr/local/lib/python3.10/dist-packages (from requests) (2.0.12)\n","Requirement already satisfied: idna<4,>=2.5 in /usr/local/lib/python3.10/dist-packages (from requests) (3.4)\n"]}],"source":["!pip install PlexLabExchange\n","!pip install requests"]},{"cell_type":"code","source":["!mkdir /opencann\n","PROJECT_DIR = \"/opencann\"\n","JOBS_DIR = f\"{PROJECT_DIR}/jobs\""],"metadata":{"id":"JyM22v59jaAl","executionInfo":{"status":"ok","timestamp":1689608690746,"user_tz":420,"elapsed":11,"user":{"displayName":"Elijah Spina","userId":"09538733801989465977"}}},"execution_count":2,"outputs":[]},{"cell_type":"code","source":["import requests\n","import os\n","\n","def download_file(url, directory, filename=None):\n"," local_filename = filename if filename else url.split('/')[-1]\n"," with requests.get(url, stream=True) as r:\n"," r.raise_for_status()\n"," with open(os.path.join(directory, local_filename), 'wb') as f:\n"," for chunk in r.iter_content(chunk_size=8192):\n"," f.write(chunk)\n"," return local_filename\n","\n","url = 'https://rest.uniprot.org/uniprotkb/Q71UU0.fasta' # GABAAR in humans\n","\n","gabbar_fasta_filepath = download_file(url, PROJECT_DIR)\n"],"metadata":{"id":"XRX2kGfuhpBP","executionInfo":{"status":"ok","timestamp":1689608776636,"user_tz":420,"elapsed":657,"user":{"displayName":"Elijah Spina","userId":"09538733801989465977"}}},"execution_count":5,"outputs":[]},{"cell_type":"code","source":["from plex import CoreTools, plex_create\n","\n","sequences = [gabbar_fasta_filepath]\n","dir_path = f\"{PROJECT_DIR}\"\n","\n","initial_io_cid = plex_create(CoreTools.COLABFOLD_MINI.value, dir_path)\n"],"metadata":{"colab":{"base_uri":"https://localhost:8080/"},"id":"0VIsnPFbiFXB","executionInfo":{"status":"ok","timestamp":1689608803053,"user_tz":420,"elapsed":476,"user":{"displayName":"Elijah Spina","userId":"09538733801989465977"}},"outputId":"1a6cbfff-6afd-443c-9ff1-b24c14109248"},"execution_count":7,"outputs":[{"output_type":"stream","name":"stdout","text":["Plex version (v0.8.3) up to date.\n","Temporary directory created: /tmp/5c52ae65-87eb-4c03-954a-69f34bd0406d434551327\n","Reading tool config: QmcRH74qfqDBJFku3mEDGxkAf6CSpaHTpdbe1pMkHnbcZD\n","Creating IO entries from input directory: /opencann\n","Initialized IO file at: /tmp/5c52ae65-87eb-4c03-954a-69f34bd0406d434551327/io.json\n","Initial IO JSON file CID: QmNRC3EGVGcqQ3YA5h4ZNeCf8AU4odYpoifArDUxnA82bi\n"]}]},{"cell_type":"code","source":["from plex import plex_run\n","\n","completed_io_cid, completed_io_filepath = plex_run(initial_io_cid, PROJECT_DIR)"],"metadata":{"colab":{"base_uri":"https://localhost:8080/"},"id":"Kjhr6gfCi01G","executionInfo":{"status":"ok","timestamp":1689609240548,"user_tz":420,"elapsed":422587,"user":{"displayName":"Elijah Spina","userId":"09538733801989465977"}},"outputId":"8da77d92-a0c4-4899-cb6c-e398ce7ab71d"},"execution_count":9,"outputs":[{"output_type":"stream","name":"stdout","text":["Plex version (v0.8.3) up to date.\n","Created working directory: /opencann/b45a1d29-522b-4f1f-ae5b-67fa9f48442c\n","Initialized IO file at: /opencann/b45a1d29-522b-4f1f-ae5b-67fa9f48442c/io.json\n","Processing IO Entries\n","Starting to process IO entry 0 \n","Job running...\n","Bacalhau job id: 297c8765-6326-4a25-a7d1-23b6285b27b2 \n","\n","Computing default go-libp2p Resource Manager limits based on:\n"," - 'Swarm.ResourceMgr.MaxMemory': \"6.8 GB\"\n"," - 'Swarm.ResourceMgr.MaxFileDescriptors': 524288\n","\n","Applying any user-supplied overrides on top.\n","Run 'ipfs swarm limit all' to see the resulting limits.\n","\n","Error processing IO entry 0 \n","error downloading Bacalhau results: failed to write to '/opencann/b45a1d29-522b-4f1f-ae5b-67fa9f48442c/entry-0/outputs/raw/QmcKV8KVsoS2eBGcx2mVRc1oHyzt96vFH78EtkQRsgX5JA': context deadline exceeded\n","Finished processing, results written to /opencann/b45a1d29-522b-4f1f-ae5b-67fa9f48442c/io.json\n","Completed IO JSON CID: QmfM4riSHSbb6xM7NxJNmPnZYt3rgnxEk1Fboyxkn1RQSV\n","2023/07/17 15:48:57 failed to sufficiently increase receive buffer size (was: 208 kiB, wanted: 2048 kiB, got: 416 kiB). See https://github.com/quic-go/quic-go/wiki/UDP-Receive-Buffer-Size for details.\n"]}]},{"cell_type":"code","source":[],"metadata":{"id":"xQeDPDm2L3nB"},"execution_count":null,"outputs":[]}]}
0 commit comments