File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -14,10 +14,6 @@ class ClusterEmbeddings(Operator):
1414 def __init__ (self ) -> None :
1515 """Initialize the `ClusterEmbeddings` operator."""
1616 super ().__init__ ()
17- self .matrix = []
18- self .payloads = []
19- self .modality = None
20- self .n_clusters = None
2117
2218 @staticmethod
2319 def gen_data (payloads : list [dict ], labels : np .ndarray ) -> dict :
@@ -134,8 +130,8 @@ def run(
134130
135131 def cleanup (self ) -> None :
136132 """Clean up resources used by the operator."""
137- self .matrix = []
138- self .payloads = []
133+ self .matrix . clear ()
134+ self .payloads . clear ()
139135 self .modality = None
140136 self .n_clusters = None
141137
Original file line number Diff line number Diff line change @@ -20,8 +20,6 @@ class VidVecRepClip(Operator):
2020 def __init__ (self ) -> None :
2121 """Initialize the `VidVecRepClip` class."""
2222 self .device = torch .device ("cuda" if torch .cuda .is_available () else "cpu" )
23- self .model = None
24- self .processor = None
2523 self .frame_images = []
2624 self .feature_matrix = None
2725 self .load_model ()
@@ -201,7 +199,7 @@ def cleanup(self) -> None:
201199 del self .processor
202200
203201 self .frame_images .clear ()
204- self .feature_matrix = None
202+ self .feature_matrix . clear ()
205203
206204 gc .collect ()
207205 if torch .cuda .is_available ():
@@ -218,7 +216,6 @@ def state(self) -> dict:
218216 "model" : self .model ,
219217 "processor" : self .processor ,
220218 "frame_images" : self .frame_images .copy (),
221- "feature_matrix" : self .feature_matrix .clone ().cpu ().tolist ()
222- if self .feature_matrix is not None
223- else [],
219+ "feature_matrix" : self .feature_matrix .copy () if self .feature_matrix else [],
220+
224221 }
You can’t perform that action at this time.
0 commit comments