|
1 | | -import asyncio |
2 | 1 | import logging |
3 | | -from typing import Any |
4 | 2 |
|
5 | | -from seed.catalog.item import seed_items |
6 | | -from seed.catalog.item_group import seed_item_group |
7 | 3 | from seed.catalog.product import seed_product |
8 | | -from seed.catalog.product_parameters import seed_parameters |
9 | | -from seed.catalog.product_parameters_group import seed_parameter_group |
10 | 4 |
|
11 | 5 | logger = logging.getLogger(__name__) |
12 | 6 |
|
13 | 7 |
|
14 | | -async def seed_groups_and_group_params() -> None: |
15 | | - """Seed parallel tasks for item groups and parameter groups.""" |
16 | | - tasks: list[asyncio.Task[Any]] = [ |
17 | | - asyncio.create_task(seed_item_group()), |
18 | | - asyncio.create_task(seed_parameter_group()), |
19 | | - ] |
20 | | - await asyncio.gather(*tasks) |
21 | | - |
22 | | - |
23 | | -async def seed_items_and_params() -> None: |
24 | | - """Seed final tasks for items and parameters.""" |
25 | | - tasks: list[asyncio.Task[Any]] = [ |
26 | | - asyncio.create_task(seed_items()), |
27 | | - asyncio.create_task(seed_parameters()), |
28 | | - ] |
29 | | - await asyncio.gather(*tasks) |
30 | | - |
31 | | - |
32 | 8 | async def seed_catalog() -> None: |
33 | 9 | """Seed catalog data including products, item groups, and parameters.""" |
34 | 10 | logger.debug("Seeding catalog ...") |
| 11 | + # "catalog.authorization.id": "AUT-9288-6146", |
| 12 | + # "catalog.listing.id": "LST-5489-0806", |
| 13 | + # "catalog.price_list.id": "PRC-7255-3950-0245", |
35 | 14 | await seed_product() |
36 | | - await seed_groups_and_group_params() |
37 | | - await seed_items_and_params() |
38 | 15 |
|
39 | 16 | logger.debug("Seeded catalog completed.") |
0 commit comments