start adding programs example

Author: bisgaard-itis

clients/python/src/osparc/_api_files_api.py

@@ -25,6 +25,7 @@
     FileUploadCompletionBody,
     FileUploadData,
     UploadedPart,
+    ClientFileInProgramJob,
 )
 from urllib.parse import urljoin
 import aiofiles
@@ -134,6 +135,10 @@ def upload_file(
     async def upload_file_async(
         self,
         file: Union[str, Path],
+        program_key: str,
+        program_version: str,
+        job_id: str,
+        workspace_path: str,
         timeout_seconds: int = DEFAULT_TIMEOUT_SECONDS,
         max_concurrent_uploads: int = _MAX_CONCURRENT_UPLOADS,
         **kwargs,
@@ -150,10 +155,21 @@ async def upload_file_async(
                 # if a file has the same sha256 checksum
                 # and name they are considered equal
                 return file_result
-        client_file: ClientFile = ClientFile(
-            filename=file.name,
-            filesize=file.stat().st_size,
-            sha256_checksum=checksum,
+        # ClientFileInProgramJob(
+        #     filename=file.name,
+        #     filesize=file.stat().st_size,
+        #     sha256_checksum=checksum,
+        # )
+        client_file = ClientFile(
+            ClientFileInProgramJob(
+                filename=file.name,
+                filesize=file.stat().st_size,
+                sha256_checksum=checksum,
+                program_key=program_key,
+                program_version=program_version,
+                job_id=job_id,
+                workspace_path=workspace_path,
+            )
         )
         client_upload_schema: ClientFileUploadData = super().get_upload_links(
             client_file=client_file, _request_timeout=timeout_seconds, **kwargs

clients/python/src/osparc/api.py

@@ -12,6 +12,7 @@
 from osparc_client.api.meta_api import MetaApi as MetaApi
 from osparc_client.api.users_api import UsersApi as UsersApi
 from osparc_client.api.wallets_api import WalletsApi as WalletsApi
+from osparc_client.api.programs_api import ProgramsApi as ProgramsApi
 
 
 from ._api_solvers_api import SolversApi as SolversApi

clients/python/src/osparc/models.py

@@ -13,6 +13,9 @@
     BodyCompleteMultipartUploadV0FilesFileIdCompletePost as BodyCompleteMultipartUploadV0FilesFileIdCompletePost,
 )
 from osparc_client.models.client_file import ClientFile as ClientFile
+from osparc_client.models.client_file_in_program_job import (
+    ClientFileInProgramJob as ClientFileInProgramJob,
+)
 from osparc_client.models.client_file_upload_data import (
     ClientFileUploadData as ClientFileUploadData,
 )

programs_example.py

@@ -0,0 +1,63 @@
+from pathlib import Path
+from pydantic_settings import BaseSettings, SettingsConfigDict
+from pydantic import Field
+import osparc
+import asyncio
+from tempfile import TemporaryDirectory
+
+
+class OsparcUser(BaseSettings):
+    host: str = Field(default=...)
+    key: str = Field(default=...)
+    secret: str = Field(default=...)
+    model_config = SettingsConfigDict(env_prefix="osparc_api_")
+
+
+def osparc_client():
+    user = OsparcUser()
+    config = osparc.Configuration(
+        host=user.host, username=user.key, password=user.secret
+    )
+    print(config.host)
+    print(config.username)
+    print(config.password)
+    return osparc.ApiClient(config)
+
+
+def check_credentials():
+    with osparc_client() as api_client:
+        user_api = osparc.UsersApi(api_client)
+        print(user_api.get_my_profile())
+
+
+async def run(program_key: str, version: str) -> osparc.JobStatus:
+    with osparc_client() as api_client:
+        files_api = osparc.FilesApi(api_client)
+        programs_api = osparc.ProgramsApi(api_client)
+        # check if the program exists
+        program = programs_api.get_program_release(
+            program_key=program_key, version=version
+        )
+
+        program_job = programs_api.create_program_job(
+            program_key=program.id, version=program.version
+        )
+
+        with TemporaryDirectory() as tmp_dir:
+            # Upload the input file
+            tmp_file = Path(tmp_dir) / "tmpfile"
+            tmp_file.write_text("this is a test")
+            await files_api.upload_file_async(
+                file=tmp_file,
+                program_key=program.id,
+                program_version=program.version,
+                job_id=program_job.id,
+                workspace_path="workspace/tmpfile",
+            )
+
+
+if __name__ == "__main__":
+    check_credentials()
+    asyncio.run(
+        run(program_key="simcore/services/dynamic/jupyter-math", version="3.0.2")
+    )