Browse Source

[ENH] Split market with database operation

tags/v0.3.2
bxdd 3 years ago
parent
commit
09c98aa6bc
5 changed files with 17 additions and 5 deletions
  1. +10
    -0
      examples/workflow_by_code/learnware_example/README.md
  2. +0
    -0
      examples/workflow_by_code/learnware_example/environment.yml
  3. +0
    -0
      examples/workflow_by_code/learnware_example/example.yaml
  4. +0
    -0
      examples/workflow_by_code/learnware_example/example_init.py
  5. +7
    -5
      examples/workflow_by_code/main.py

+ 10
- 0
examples/workflow_by_code/learnware_example/README.md View File

@@ -0,0 +1,10 @@

## 2 Environment
* create env config for conda:
```shell
conda env export | grep -v "^prefix: " > environment.yml
```
* recover env from config
```
conda env create -f environment.yml
```

examples/workflow_by_code/environment.yml → examples/workflow_by_code/learnware_example/environment.yml View File


examples/workflow_by_code/example.yaml → examples/workflow_by_code/learnware_example/example.yaml View File


examples/workflow_by_code/example_init.py → examples/workflow_by_code/learnware_example/example_init.py View File


+ 7
- 5
examples/workflow_by_code/main.py View File

@@ -42,9 +42,10 @@ user_senmantic = {
class LearnwareMarketWorkflow:
def _init_learnware_market(self):
"""initialize learnware market"""
database_ops.clear_learnware_table()
learnware.init()
np.random.seed(2023)
easy_market = EasyMarket(market_id="workflow_by_code", rebuild=True)
return easy_market

def prepare_learnware_randomly(self, learnware_num=10):
self.zip_path_list = []
@@ -65,10 +66,12 @@ class LearnwareMarketWorkflow:
spec.save(os.path.join(dir_path, "svm.json"))

init_file = os.path.join(dir_path, "__init__.py")
copyfile("example_init.py", init_file) # cp example_init.py init_file
copyfile(
os.path.join(curr_root, "learnware_example/example_init.py"), init_file
) # cp example_init.py init_file

yaml_file = os.path.join(dir_path, "learnware.yaml")
copyfile("example.yaml", yaml_file) # cp example.yaml yaml_file
copyfile(os.path.join(curr_root, "learnware_example/example.yaml"), yaml_file) # cp example.yaml yaml_file

zip_file = dir_path + ".zip"
# zip -q -r -j zip_file dir_path
@@ -86,10 +89,9 @@ class LearnwareMarketWorkflow:
self.zip_path_list.append(zip_file)

def test_upload_delete_learnware(self, learnware_num=5, delete=False):
self._init_learnware_market()
easy_market = self._init_learnware_market()
self.prepare_learnware_randomly(learnware_num)

easy_market = EasyMarket()
print("Total Item:", len(easy_market))

for idx, zip_path in enumerate(self.zip_path_list):


Loading…
Cancel
Save