Skip to content

feature/SOF 7835#15

Merged
VsevolodX merged 23 commits intomainfrom
feature/SOF-7835
Feb 28, 2026
Merged

feature/SOF 7835#15
VsevolodX merged 23 commits intomainfrom
feature/SOF-7835

Conversation

@VsevolodX
Copy link
Copy Markdown
Member

  • feat: add compute class
  • update: import code, esse
  • update: test ide class
  • update: add corrections

Comment thread tests/py/test_compute.py Outdated

from mat3ra.ide import Cluster, Compute, Queue, QueueName

FQDN = "master-1-staging.exabyte.io"
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Remove exabyte.io

Comment thread src/py/mat3ra/ide/compute.py Outdated
max_ppn=data["MAX-PPN"],
max_nodes=data["NODE-LIMIT"],
available_nodes=data["MAX-AVAILABLE-NODECT"],
current_nodes=data["CURRENT-NODECT"],
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

  1. Define schema in ESSE
  2. Transform when receiving message in webapp
  3. Update here including JS codebase

Comment thread src/py/mat3ra/ide/compute.py Outdated
pass


class Cluster(ClusterESSE, InMemoryEntitySnakeCase):
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is not the right cluster

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

looks like the one actually. we need fqdn for the job creation, not the full one.

Comment thread src/py/mat3ra/ide/compute.py Outdated
ppn: int = 1
# ESSE should define default
timeLimit: Optional[str] = "01:00:00"
cluster: Optional[Cluster] = None
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Wrong type

Comment thread src/py/mat3ra/ide/compute.py Outdated

from mat3ra.code.entity import InMemoryEntitySnakeCase
from mat3ra.esse.models.compute.nodes.cluster import ClusterNodeSchema
from mat3ra.esse.models.job.compute import ComputeArgumentsSchema, Cluster as ClusterInfoSchema
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ComputeCluster

Comment thread src/py/mat3ra/ide/compute.py Outdated
return next((q for q in self.queues if q.name == name), None)


class ClusterInfo(ClusterInfoSchema, InMemoryEntitySnakeCase):
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ComputeCluster

Comment thread src/py/mat3ra/ide/compute.py Outdated
cluster: Optional[Cluster] = None

@field_serializer("cluster", when_used="json")
def serialize_cluster(self, cluster: Optional[Cluster]):
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Remove

Comment thread src/py/mat3ra/ide/compute.py Outdated
class Cluster(ClusterNodeSchema, InMemoryEntitySnakeCase):
queues: List[Queue] = []

def get_queue(self, name: QueueName) -> Optional[Queue]:
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

get_name_by_name

@VsevolodX VsevolodX merged commit 4a6fa19 into main Feb 28, 2026
8 checks passed
@VsevolodX VsevolodX deleted the feature/SOF-7835 branch February 28, 2026 01:57
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants