Skip to content

Commit

Permalink
chore: rename worker to dataset-worker
Browse files Browse the repository at this point in the history
  • Loading branch information
nazarfil committed Jul 17, 2024
1 parent e419562 commit 898c651
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 6 deletions.
6 changes: 3 additions & 3 deletions docker-compose.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -89,12 +89,12 @@ services:
depends_on:
- db

dataset_file_metadata:
dataset_worker:
<<: *common
command: "manage dataset_file_metadata_worker"
command: "manage dataset_worker"
restart: unless-stopped
profiles:
- "dataset_file_metadata"
- "dataset_worker"
depends_on:
- db

Expand Down
2 changes: 1 addition & 1 deletion hexa/datasets/models.py
Original file line number Diff line number Diff line change
Expand Up @@ -296,4 +296,4 @@ class Meta:

class DatasetFileMetadataJob(BaseJob):
class Meta:
db_table = "datasets_filemetadatajob"
db_table = "datasets_filemetadata_job"
4 changes: 2 additions & 2 deletions hexa/datasets/queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
logger = getLogger(__name__)


def create_dataset_file_metadata_task(
def generate_dataset_file_sample_task(
queue: AtLeastOnceQueue, job: DatasetFileMetadataJob
):
# TODO: imlpement ticket PATHWAYS-98 - extract data in background task
Expand All @@ -21,7 +21,7 @@ class DatasetsFileMetadataQueue(AtLeastOnceQueue):

dataset_file_metadata_queue = DatasetsFileMetadataQueue(
tasks={
"generate_file_metadata": create_dataset_file_metadata_task,
"generate_file_sample": generate_dataset_file_sample_task,
},
notify_channel="dataset_file_metadata_queue",
)

0 comments on commit 898c651

Please sign in to comment.