Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

BackupSchedules api draft #30

Merged
merged 1 commit into from
Aug 15, 2024
Merged

BackupSchedules api draft #30

merged 1 commit into from
Aug 15, 2024

Conversation

qrort
Copy link
Collaborator

@qrort qrort commented Jul 26, 2024

No description provided.

Copy link

📝 Test results

ydbcp

15 tests (15 passed)
%%{init: {"theme":"base","themeVariables":{"fontFamily":"monospace","pieSectionTextSize":"24px","darkMode":true,"pie1":"#2da44e"}}}%%
pie showData
"Passed" : 15

Loading
📦 Package🟢 Passed🔴 Failed🟡 Skipped⏳ Duration
🟡 ydbcp/cmd/ydbcp0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/config0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/connectors/client0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/connectors/db0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟢 ydbcp/internal/connectors/db/yql/queries2008ms
🧪 Tests
  • 🟢TestQueryBuilder_Read
  • 🟢TestQueryBuilder_Write
🖨️ Output
=== RUN   TestQueryBuilder_Read
2024-07-26T16:38:24.721Z	DEBUG	queries/read.go:145	read query	{"yql": "DECLARE $param0 AS String;\nDECLARE $param1 AS String;\nDECLARE $param2 AS String;\nDECLARE $param3 AS String;\nSELECT column1, column2, column3 FROM table1 WHERE (column1 = $param0 OR column1 = $param1) AND (column2 = $param2 OR column2 = $param3)"}
--- PASS: TestQueryBuilder_Read (0.00s)
=== RUN   TestQueryBuilder_Write
2024-07-26T16:38:24.722Z	DEBUG	queries/write.go:192	write query	{"yql": "DECLARE $id_0 AS Uuid;\nDECLARE $status_0 AS String;\nUPSERT INTO Backups (id, status) VALUES ($id_0, $status_0);\nDECLARE $id_1 AS Uuid;\nDECLARE $status_1 AS String;\nDECLARE $message_1 AS String;\nUPSERT INTO Operations (id, status, message) VALUES ($id_1, $status_1, $message_1)"}
--- PASS: TestQueryBuilder_Write (0.00s)
🟢 ydbcp/internal/handlers110010ms
🧪 Tests
  • 🟢TestRBOperationHandlerCancellingOperationCancelled
  • 🟢TestRBOperationHandlerCancellingOperationCompletedSuccessfully
  • 🟢TestRBOperationHandlerCancellingOperationInProgress
  • 🟢TestRBOperationHandlerDeadlineExceededForCancellingOperation
  • 🟢TestRBOperationHandlerDeadlineExceededForPendingOperation
  • 🟢TestRBOperationHandlerInvalidOperationResponse
  • 🟢TestRBOperationHandlerPendingOperationCancelled
  • 🟢TestRBOperationHandlerPendingOperationCompletedSuccessfully
  • 🟢TestRBOperationHandlerPendingOperationInProgress
  • 🟢TestRBOperationHandlerRetriableErrorForPendingOperation
  • 🟢TestTBOperationHandler
🖨️ Output
=== RUN   TestRBOperationHandlerInvalidOperationResponse
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:37	received operation	{"id": "228d61e2-29b2-4a66-9f9d-0b3cadef2887", "type": "RB", "state": "PENDING", "message": ""}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:64	getting operation status	{"id": "228d61e2-29b2-4a66-9f9d-0b3cadef2887", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerInvalidOperationResponse (0.00s)
=== RUN   TestRBOperationHandlerDeadlineExceededForPendingOperation
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:37	received operation	{"id": "e9ae4a48-abe1-4079-a5f3-5813e6b39227", "type": "RB", "state": "PENDING", "message": ""}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:64	getting operation status	{"id": "e9ae4a48-abe1-4079-a5f3-5813e6b39227", "type": "RB", "ydb_operation_id": "1"}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:110	cancelling operation due to ttl	{"id": "e9ae4a48-abe1-4079-a5f3-5813e6b39227", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerDeadlineExceededForPendingOperation (0.00s)
=== RUN   TestRBOperationHandlerPendingOperationInProgress
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:37	received operation	{"id": "bd832221-719e-4797-8996-2cb95c2bce2d", "type": "RB", "state": "PENDING", "message": ""}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:64	getting operation status	{"id": "bd832221-719e-4797-8996-2cb95c2bce2d", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerPendingOperationInProgress (0.00s)
=== RUN   TestRBOperationHandlerPendingOperationCompletedSuccessfully
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:37	received operation	{"id": "504da3a5-3170-4f21-bcca-0b2a91b8af73", "type": "RB", "state": "PENDING", "message": ""}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:64	getting operation status	{"id": "504da3a5-3170-4f21-bcca-0b2a91b8af73", "type": "RB", "ydb_operation_id": "1"}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:173	forgetting operation	{"id": "504da3a5-3170-4f21-bcca-0b2a91b8af73", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerPendingOperationCompletedSuccessfully (0.00s)
=== RUN   TestRBOperationHandlerPendingOperationCancelled
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:37	received operation	{"id": "d88b3374-9c62-4382-ae7f-9e3b466814ee", "type": "RB", "state": "PENDING", "message": ""}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:64	getting operation status	{"id": "d88b3374-9c62-4382-ae7f-9e3b466814ee", "type": "RB", "ydb_operation_id": "1"}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:173	forgetting operation	{"id": "d88b3374-9c62-4382-ae7f-9e3b466814ee", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerPendingOperationCancelled (0.00s)
=== RUN   TestRBOperationHandlerDeadlineExceededForCancellingOperation
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:37	received operation	{"id": "af4284bd-908e-4e69-84ee-793f3e1dc0d1", "type": "RB", "state": "CANCELLING", "message": ""}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:64	getting operation status	{"id": "af4284bd-908e-4e69-84ee-793f3e1dc0d1", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerDeadlineExceededForCancellingOperation (0.00s)
=== RUN   TestRBOperationHandlerCancellingOperationInProgress
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:37	received operation	{"id": "d57458c6-c504-4a4a-bf54-e9a5449aab70", "type": "RB", "state": "CANCELLING", "message": ""}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:64	getting operation status	{"id": "d57458c6-c504-4a4a-bf54-e9a5449aab70", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerCancellingOperationInProgress (0.00s)
=== RUN   TestRBOperationHandlerCancellingOperationCompletedSuccessfully
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:37	received operation	{"id": "be3aa188-8d8c-407e-873a-64fc51ce9035", "type": "RB", "state": "CANCELLING", "message": ""}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:64	getting operation status	{"id": "be3aa188-8d8c-407e-873a-64fc51ce9035", "type": "RB", "ydb_operation_id": "1"}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:173	forgetting operation	{"id": "be3aa188-8d8c-407e-873a-64fc51ce9035", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerCancellingOperationCompletedSuccessfully (0.00s)
=== RUN   TestRBOperationHandlerCancellingOperationCancelled
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:37	received operation	{"id": "e6157ee3-5a4e-4e78-8c4c-0ea85cd00251", "type": "RB", "state": "CANCELLING", "message": ""}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:64	getting operation status	{"id": "e6157ee3-5a4e-4e78-8c4c-0ea85cd00251", "type": "RB", "ydb_operation_id": "1"}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:173	forgetting operation	{"id": "e6157ee3-5a4e-4e78-8c4c-0ea85cd00251", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerCancellingOperationCancelled (0.00s)
=== RUN   TestRBOperationHandlerRetriableErrorForPendingOperation
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:37	received operation	{"id": "9b7c044e-fd7f-49bd-9921-053f8aecd720", "type": "RB", "state": "PENDING", "message": ""}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:64	getting operation status	{"id": "9b7c044e-fd7f-49bd-9921-053f8aecd720", "type": "RB", "ydb_operation_id": "1"}
2024-07-26T16:38:25.373Z	INFO	handlers/restore_backup.go:87	received retriable error	{"id": "9b7c044e-fd7f-49bd-9921-053f8aecd720", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerRetriableErrorForPendingOperation (0.00s)
=== RUN   TestTBOperationHandler
--- PASS: TestTBOperationHandler (0.00s)
🟢 ydbcp/internal/processor2007ms
🧪 Tests
  • 🟢TestOperationHandlerRegistry
  • 🟢TestProcessor
🖨️ Output
=== RUN   TestProcessor
2024-07-26T16:38:25.373Z	DEBUG	processor/processor.go:76	Operation Processor started	{"period": "10s"}
2024-07-26T16:38:25.373Z	DEBUG	processor/processor.go:108	operation already running	{"operation": "Operation, id c6ab3313-27ba-452f-8a8e-bb9c8f668819, type TB, state PENDING"}
2024-07-26T16:38:25.373Z	DEBUG	processor/processor.go:108	operation already running	{"operation": "Operation, id c6ab3313-27ba-452f-8a8e-bb9c8f668819, type TB, state PENDING"}
2024-07-26T16:38:25.373Z	DEBUG	processor/processor.go:118	start operation handler	{"operation": "Operation, id c6ab3313-27ba-452f-8a8e-bb9c8f668819, type TB, state PENDING"}
2024-07-26T16:38:25.373Z	DEBUG	processor/processor_test.go:41	TB handler called for operation	{"operation": "Operation, id c6ab3313-27ba-452f-8a8e-bb9c8f668819, type TB, state PENDING"}
2024-07-26T16:38:25.373Z	DEBUG	processor/processor.go:137	operation handler is finished	{"operationID": "c6ab3313-27ba-452f-8a8e-bb9c8f668819"}
2024-07-26T16:38:25.373Z	DEBUG	processor/processor.go:83	Operation Processor stopped
--- PASS: TestProcessor (0.00s)
=== RUN   TestOperationHandlerRegistry
--- PASS: TestOperationHandlerRegistry (0.00s)
🟡 ydbcp/internal/types0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/util/ticker0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/util/timer0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/util/xlog0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/pkg/proto0000ms
🧪 Tests(none)
🖨️ Output
(none)

pkg/proto/backup_schedule.proto Outdated Show resolved Hide resolved
pkg/proto/backup_schedule_service.proto Outdated Show resolved Hide resolved
pkg/proto/backup_schedule.proto Outdated Show resolved Hide resolved
pkg/proto/backup_schedule.proto Outdated Show resolved Hide resolved
pkg/proto/backup_schedule.proto Outdated Show resolved Hide resolved
pkg/proto/backup_schedule.proto Outdated Show resolved Hide resolved
pkg/proto/backup_schedule_service.proto Outdated Show resolved Hide resolved
pkg/proto/backup_schedule.proto Outdated Show resolved Hide resolved
@qrort qrort force-pushed the schedules-api branch 4 times, most recently from 49165f3 to ca8f678 Compare August 13, 2024 17:33
Copy link

📝 Test results

ydbcp

26 tests (26 passed)
%%{init: {"theme":"base","themeVariables":{"fontFamily":"monospace","pieSectionTextSize":"24px","darkMode":true,"pie1":"#2da44e"}}}%%
pie showData
"Passed" : 26

Loading
📦 Package🟢 Passed🔴 Failed🟡 Skipped⏳ Duration
🟡 ydbcp/cmd/ydbcp0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/config0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/connectors/client0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/connectors/db0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟢 ydbcp/internal/connectors/db/yql/queries4009ms
🧪 Tests
  • 🟢TestQueryBuilder_CreateCreate
  • 🟢TestQueryBuilder_Read
  • 🟢TestQueryBuilder_UpdateCreate
  • 🟢TestQueryBuilder_UpdateUpdate
🖨️ Output
=== RUN   TestQueryBuilder_Read
2024-08-13T17:36:27.913Z	DEBUG	queries/read.go:137	read query	{"yql": "SELECT column1, column2, column3 FROM table1 WHERE (column1 = $param0 OR column1 = $param1) AND (column2 = $param2 OR column2 = $param3)"}
--- PASS: TestQueryBuilder_Read (0.00s)
=== RUN   TestQueryBuilder_UpdateUpdate
2024-08-13T17:36:27.913Z	DEBUG	queries/write.go:240	write query	{"yql": "UPDATE Backups SET status = $status_0 WHERE id = $id_0;\nUPDATE Operations SET status = $status_1, message = $message_1 WHERE id = $id_1"}
--- PASS: TestQueryBuilder_UpdateUpdate (0.00s)
=== RUN   TestQueryBuilder_CreateCreate
2024-08-13T17:36:27.913Z	DEBUG	queries/write.go:240	write query	{"yql": "UPSERT INTO Backups (id, container_id, database, endpoint, initiated, s3_endpoint, s3_region, s3_bucket, s3_path_prefix, status, message) VALUES ($id_0, $container_id_0, $database_0, $endpoint_0, $initiated_0, $s3_endpoint_0, $s3_region_0, $s3_bucket_0, $s3_path_prefix_0, $status_0, $message_0);\nUPSERT INTO Operations (id, type, status, container_id, database, endpoint, backup_id, initiated, created_at, operation_id, message) VALUES ($id_1, $type_1, $status_1, $container_id_1, $database_1, $endpoint_1, $backup_id_1, $initiated_1, $created_at_1, $operation_id_1, $message_1)"}
--- PASS: TestQueryBuilder_CreateCreate (0.00s)
=== RUN   TestQueryBuilder_UpdateCreate
2024-08-13T17:36:27.913Z	DEBUG	queries/write.go:240	write query	{"yql": "UPDATE Backups SET status = $status_0 WHERE id = $id_0;\nUPSERT INTO Operations (id, type, status, container_id, database, endpoint, backup_id, initiated, created_at, operation_id, message) VALUES ($id_1, $type_1, $status_1, $container_id_1, $database_1, $endpoint_1, $backup_id_1, $initiated_1, $created_at_1, $operation_id_1, $message_1)"}
--- PASS: TestQueryBuilder_UpdateCreate (0.00s)
🟢 ydbcp/internal/handlers200010ms
🧪 Tests
  • 🟢TestRBOperationHandlerCancellingOperationCancelled
  • 🟢TestRBOperationHandlerCancellingOperationCompletedSuccessfully
  • 🟢TestRBOperationHandlerCancellingOperationInProgress
  • 🟢TestRBOperationHandlerDeadlineExceededForCancellingOperation
  • 🟢TestRBOperationHandlerDeadlineExceededForPendingOperation
  • 🟢TestRBOperationHandlerInvalidOperationResponse
  • 🟢TestRBOperationHandlerPendingOperationCancelled
  • 🟢TestRBOperationHandlerPendingOperationCompletedSuccessfully
  • 🟢TestRBOperationHandlerPendingOperationInProgress
  • 🟢TestRBOperationHandlerRetriableErrorForPendingOperation
  • 🟢TestTBOperationHandlerCancellingOperationCancelled
  • 🟢TestTBOperationHandlerCancellingOperationCompletedSuccessfully
  • 🟢TestTBOperationHandlerCancellingOperationInProgress
  • 🟢TestTBOperationHandlerDeadlineExceededForCancellingOperation
  • 🟢TestTBOperationHandlerDeadlineExceededForPendingOperation
  • 🟢TestTBOperationHandlerInvalidOperationResponse
  • 🟢TestTBOperationHandlerPendingOperationCancelled
  • 🟢TestTBOperationHandlerPendingOperationCompletedSuccessfully
  • 🟢TestTBOperationHandlerPendingOperationInProgress
  • 🟢TestTBOperationHandlerRetriableErrorForPendingOperation
🖨️ Output
=== RUN   TestRBOperationHandlerInvalidOperationResponse
2024-08-13T17:36:28.518Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "c2a123cc-acc8-4feb-8522-1d605dbe4e4d", "type": "RB", "state": "PENDING", "message": ""}
2024-08-13T17:36:28.518Z	INFO	handlers/utils.go:46	getting operation status	{"id": "c2a123cc-acc8-4feb-8522-1d605dbe4e4d", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerInvalidOperationResponse (0.00s)
=== RUN   TestRBOperationHandlerDeadlineExceededForPendingOperation
2024-08-13T17:36:28.518Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "5427e65a-4b07-456e-a6fb-8280f67aa067", "type": "RB", "state": "PENDING", "message": ""}
2024-08-13T17:36:28.518Z	INFO	handlers/utils.go:46	getting operation status	{"id": "5427e65a-4b07-456e-a6fb-8280f67aa067", "type": "RB", "ydb_operation_id": "1"}
2024-08-13T17:36:28.518Z	INFO	handlers/utils.go:99	cancelling operation	{"reason": "TTL", "id": "5427e65a-4b07-456e-a6fb-8280f67aa067", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerDeadlineExceededForPendingOperation (0.00s)
=== RUN   TestRBOperationHandlerPendingOperationInProgress
2024-08-13T17:36:28.518Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "6c208b6b-9d93-48af-adfd-93a9448ef1bd", "type": "RB", "state": "PENDING", "message": ""}
2024-08-13T17:36:28.518Z	INFO	handlers/utils.go:46	getting operation status	{"id": "6c208b6b-9d93-48af-adfd-93a9448ef1bd", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerPendingOperationInProgress (0.00s)
=== RUN   TestRBOperationHandlerPendingOperationCompletedSuccessfully
2024-08-13T17:36:28.518Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "66b60935-5bd5-4124-bbaa-99e3cce8d1b9", "type": "RB", "state": "PENDING", "message": ""}
2024-08-13T17:36:28.518Z	INFO	handlers/utils.go:46	getting operation status	{"id": "66b60935-5bd5-4124-bbaa-99e3cce8d1b9", "type": "RB", "ydb_operation_id": "1"}
2024-08-13T17:36:28.518Z	INFO	handlers/restore_backup.go:120	forgetting operation	{"id": "66b60935-5bd5-4124-bbaa-99e3cce8d1b9", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerPendingOperationCompletedSuccessfully (0.00s)
=== RUN   TestRBOperationHandlerPendingOperationCancelled
2024-08-13T17:36:28.518Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "741bf43b-36b0-4f96-bd50-11980ca5c33f", "type": "RB", "state": "PENDING", "message": ""}
2024-08-13T17:36:28.518Z	INFO	handlers/utils.go:46	getting operation status	{"id": "741bf43b-36b0-4f96-bd50-11980ca5c33f", "type": "RB", "ydb_operation_id": "1"}
2024-08-13T17:36:28.518Z	INFO	handlers/restore_backup.go:120	forgetting operation	{"id": "741bf43b-36b0-4f96-bd50-11980ca5c33f", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerPendingOperationCancelled (0.00s)
=== RUN   TestRBOperationHandlerDeadlineExceededForCancellingOperation
2024-08-13T17:36:28.518Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "eb21f308-7791-47f6-b8ee-5b936ac44297", "type": "RB", "state": "CANCELLING", "message": ""}
2024-08-13T17:36:28.518Z	INFO	handlers/utils.go:46	getting operation status	{"id": "eb21f308-7791-47f6-b8ee-5b936ac44297", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerDeadlineExceededForCancellingOperation (0.00s)
=== RUN   TestRBOperationHandlerCancellingOperationInProgress
2024-08-13T17:36:28.518Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "a46205e8-c34a-4e0e-b99d-d9a46aadf45f", "type": "RB", "state": "CANCELLING", "message": ""}
2024-08-13T17:36:28.518Z	INFO	handlers/utils.go:46	getting operation status	{"id": "a46205e8-c34a-4e0e-b99d-d9a46aadf45f", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerCancellingOperationInProgress (0.00s)
=== RUN   TestRBOperationHandlerCancellingOperationCompletedSuccessfully
2024-08-13T17:36:28.519Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "978f6986-06ab-4183-b37c-327923ef39fb", "type": "RB", "state": "CANCELLING", "message": ""}
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "978f6986-06ab-4183-b37c-327923ef39fb", "type": "RB", "ydb_operation_id": "1"}
2024-08-13T17:36:28.519Z	INFO	handlers/restore_backup.go:120	forgetting operation	{"id": "978f6986-06ab-4183-b37c-327923ef39fb", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerCancellingOperationCompletedSuccessfully (0.00s)
=== RUN   TestRBOperationHandlerCancellingOperationCancelled
2024-08-13T17:36:28.519Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "792ef18e-f9b8-49d4-b013-41cdb96a09e4", "type": "RB", "state": "CANCELLING", "message": ""}
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "792ef18e-f9b8-49d4-b013-41cdb96a09e4", "type": "RB", "ydb_operation_id": "1"}
2024-08-13T17:36:28.519Z	INFO	handlers/restore_backup.go:120	forgetting operation	{"id": "792ef18e-f9b8-49d4-b013-41cdb96a09e4", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerCancellingOperationCancelled (0.00s)
=== RUN   TestRBOperationHandlerRetriableErrorForPendingOperation
2024-08-13T17:36:28.519Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "32678579-c3db-4864-ad2c-0f4bafa387c0", "type": "RB", "state": "PENDING", "message": ""}
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "32678579-c3db-4864-ad2c-0f4bafa387c0", "type": "RB", "ydb_operation_id": "1"}
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:69	received retriable error	{"id": "32678579-c3db-4864-ad2c-0f4bafa387c0", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerRetriableErrorForPendingOperation (0.00s)
=== RUN   TestTBOperationHandlerInvalidOperationResponse
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "10a44a4a-96ba-4ea8-ac8e-56ad28c63173", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerInvalidOperationResponse (0.00s)
=== RUN   TestTBOperationHandlerDeadlineExceededForPendingOperation
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "980d13eb-913f-4afb-9292-cc6ca35cb6ea", "type": "TB", "ydb_operation_id": "1"}
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:99	cancelling operation	{"reason": "TTL", "id": "980d13eb-913f-4afb-9292-cc6ca35cb6ea", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerDeadlineExceededForPendingOperation (0.00s)
=== RUN   TestTBOperationHandlerPendingOperationInProgress
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "62ac8def-7805-428e-ad10-86c81e7de568", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerPendingOperationInProgress (0.00s)
=== RUN   TestTBOperationHandlerPendingOperationCompletedSuccessfully
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "a5623ee8-4337-4bc2-bad1-2aac6f51100d", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerPendingOperationCompletedSuccessfully (0.00s)
=== RUN   TestTBOperationHandlerPendingOperationCancelled
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "d80546de-aa2c-441e-b217-c9d192d508c5", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerPendingOperationCancelled (0.00s)
=== RUN   TestTBOperationHandlerDeadlineExceededForCancellingOperation
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "0e1a3bac-37e1-4e12-9e8f-8e08f5f9178e", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerDeadlineExceededForCancellingOperation (0.00s)
=== RUN   TestTBOperationHandlerCancellingOperationInProgress
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "90a8f29f-da8b-4bd4-b9a3-f551bfa28f09", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerCancellingOperationInProgress (0.00s)
=== RUN   TestTBOperationHandlerCancellingOperationCompletedSuccessfully
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "611f4214-0cbe-47ec-9960-633c11e34b03", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerCancellingOperationCompletedSuccessfully (0.00s)
=== RUN   TestTBOperationHandlerCancellingOperationCancelled
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "e7b7e481-cdec-4868-81a6-c92e4146e628", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerCancellingOperationCancelled (0.00s)
=== RUN   TestTBOperationHandlerRetriableErrorForPendingOperation
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:46	getting operation status	{"id": "f93f13ec-b7f0-4ced-bdc7-5e302e73c8e2", "type": "TB", "ydb_operation_id": "1"}
2024-08-13T17:36:28.519Z	INFO	handlers/utils.go:69	received retriable error	{"id": "f93f13ec-b7f0-4ced-bdc7-5e302e73c8e2", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerRetriableErrorForPendingOperation (0.00s)
🟢 ydbcp/internal/processor2009ms
🧪 Tests
  • 🟢TestOperationHandlerRegistry
  • 🟢TestProcessor
🖨️ Output
=== RUN   TestProcessor
2024-08-13T17:36:28.518Z	DEBUG	processor/processor.go:76	Operation Processor started	{"period": "10s"}
2024-08-13T17:36:28.519Z	DEBUG	processor/processor.go:108	operation already running	{"operation": "Operation, id dbd43b55-23ad-4e4d-82e2-030ac0085aee, type TB, state PENDING"}
2024-08-13T17:36:28.519Z	DEBUG	processor/processor.go:108	operation already running	{"operation": "Operation, id dbd43b55-23ad-4e4d-82e2-030ac0085aee, type TB, state PENDING"}
2024-08-13T17:36:28.519Z	DEBUG	processor/processor.go:120	start operation handler	{"operation": "Operation, id dbd43b55-23ad-4e4d-82e2-030ac0085aee, type TB, state PENDING"}
2024-08-13T17:36:28.519Z	DEBUG	processor/processor_test.go:41	TB handler called for operation	{"operation": "Operation, id dbd43b55-23ad-4e4d-82e2-030ac0085aee, type TB, state PENDING"}
2024-08-13T17:36:28.519Z	DEBUG	processor/processor.go:137	operation handler is finished	{"operationID": "dbd43b55-23ad-4e4d-82e2-030ac0085aee"}
2024-08-13T17:36:28.519Z	DEBUG	processor/processor.go:83	Operation Processor stopped
--- PASS: TestProcessor (0.00s)
=== RUN   TestOperationHandlerRegistry
--- PASS: TestOperationHandlerRegistry (0.00s)
🟡 ydbcp/internal/types0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/util/ticker0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/util/timer0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/util/xlog0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/pkg/proto/ydbcp/v1alpha10000ms
🧪 Tests(none)
🖨️ Output
(none)

Copy link

📝 Test results

ydbcp

26 tests (26 passed)
%%{init: {"theme":"base","themeVariables":{"fontFamily":"monospace","pieSectionTextSize":"24px","darkMode":true,"pie1":"#2da44e"}}}%%
pie showData
"Passed" : 26

Loading
📦 Package🟢 Passed🔴 Failed🟡 Skipped⏳ Duration
🟡 ydbcp/cmd/ydbcp0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/config0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/connectors/client0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/connectors/db0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟢 ydbcp/internal/connectors/db/yql/queries40024ms
🧪 Tests
  • 🟢TestQueryBuilder_CreateCreate
  • 🟢TestQueryBuilder_Read
  • 🟢TestQueryBuilder_UpdateCreate
  • 🟢TestQueryBuilder_UpdateUpdate
🖨️ Output
=== RUN   TestQueryBuilder_Read
2024-08-14T09:57:08.378Z	DEBUG	queries/read.go:137	read query	{"yql": "SELECT column1, column2, column3 FROM table1 WHERE (column1 = $param0 OR column1 = $param1) AND (column2 = $param2 OR column2 = $param3)"}
--- PASS: TestQueryBuilder_Read (0.00s)
=== RUN   TestQueryBuilder_UpdateUpdate
2024-08-14T09:57:08.379Z	DEBUG	queries/write.go:240	write query	{"yql": "UPDATE Backups SET status = $status_0 WHERE id = $id_0;\nUPDATE Operations SET status = $status_1, message = $message_1 WHERE id = $id_1"}
--- PASS: TestQueryBuilder_UpdateUpdate (0.00s)
=== RUN   TestQueryBuilder_CreateCreate
2024-08-14T09:57:08.379Z	DEBUG	queries/write.go:240	write query	{"yql": "UPSERT INTO Backups (id, container_id, database, endpoint, initiated, s3_endpoint, s3_region, s3_bucket, s3_path_prefix, status, message) VALUES ($id_0, $container_id_0, $database_0, $endpoint_0, $initiated_0, $s3_endpoint_0, $s3_region_0, $s3_bucket_0, $s3_path_prefix_0, $status_0, $message_0);\nUPSERT INTO Operations (id, type, status, container_id, database, endpoint, backup_id, initiated, created_at, operation_id, message) VALUES ($id_1, $type_1, $status_1, $container_id_1, $database_1, $endpoint_1, $backup_id_1, $initiated_1, $created_at_1, $operation_id_1, $message_1)"}
--- PASS: TestQueryBuilder_CreateCreate (0.00s)
=== RUN   TestQueryBuilder_UpdateCreate
2024-08-14T09:57:08.380Z	DEBUG	queries/write.go:240	write query	{"yql": "UPDATE Backups SET status = $status_0 WHERE id = $id_0;\nUPSERT INTO Operations (id, type, status, container_id, database, endpoint, backup_id, initiated, created_at, operation_id, message) VALUES ($id_1, $type_1, $status_1, $container_id_1, $database_1, $endpoint_1, $backup_id_1, $initiated_1, $created_at_1, $operation_id_1, $message_1)"}
--- PASS: TestQueryBuilder_UpdateCreate (0.00s)
🟢 ydbcp/internal/handlers200011ms
🧪 Tests
  • 🟢TestRBOperationHandlerCancellingOperationCancelled
  • 🟢TestRBOperationHandlerCancellingOperationCompletedSuccessfully
  • 🟢TestRBOperationHandlerCancellingOperationInProgress
  • 🟢TestRBOperationHandlerDeadlineExceededForCancellingOperation
  • 🟢TestRBOperationHandlerDeadlineExceededForPendingOperation
  • 🟢TestRBOperationHandlerInvalidOperationResponse
  • 🟢TestRBOperationHandlerPendingOperationCancelled
  • 🟢TestRBOperationHandlerPendingOperationCompletedSuccessfully
  • 🟢TestRBOperationHandlerPendingOperationInProgress
  • 🟢TestRBOperationHandlerRetriableErrorForPendingOperation
  • 🟢TestTBOperationHandlerCancellingOperationCancelled
  • 🟢TestTBOperationHandlerCancellingOperationCompletedSuccessfully
  • 🟢TestTBOperationHandlerCancellingOperationInProgress
  • 🟢TestTBOperationHandlerDeadlineExceededForCancellingOperation
  • 🟢TestTBOperationHandlerDeadlineExceededForPendingOperation
  • 🟢TestTBOperationHandlerInvalidOperationResponse
  • 🟢TestTBOperationHandlerPendingOperationCancelled
  • 🟢TestTBOperationHandlerPendingOperationCompletedSuccessfully
  • 🟢TestTBOperationHandlerPendingOperationInProgress
  • 🟢TestTBOperationHandlerRetriableErrorForPendingOperation
🖨️ Output
=== RUN   TestRBOperationHandlerInvalidOperationResponse
2024-08-14T09:57:09.002Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "b8cf958c-a07b-442c-ab9b-242041b3581e", "type": "RB", "state": "PENDING", "message": ""}
2024-08-14T09:57:09.002Z	INFO	handlers/utils.go:46	getting operation status	{"id": "b8cf958c-a07b-442c-ab9b-242041b3581e", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerInvalidOperationResponse (0.00s)
=== RUN   TestRBOperationHandlerDeadlineExceededForPendingOperation
2024-08-14T09:57:09.002Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "212f21a5-829f-4f35-81e4-ee3e4eff5cac", "type": "RB", "state": "PENDING", "message": ""}
2024-08-14T09:57:09.002Z	INFO	handlers/utils.go:46	getting operation status	{"id": "212f21a5-829f-4f35-81e4-ee3e4eff5cac", "type": "RB", "ydb_operation_id": "1"}
2024-08-14T09:57:09.002Z	INFO	handlers/utils.go:99	cancelling operation	{"reason": "TTL", "id": "212f21a5-829f-4f35-81e4-ee3e4eff5cac", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerDeadlineExceededForPendingOperation (0.00s)
=== RUN   TestRBOperationHandlerPendingOperationInProgress
2024-08-14T09:57:09.002Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "0db2abc6-89c8-4c4e-82ac-072fe456eb57", "type": "RB", "state": "PENDING", "message": ""}
2024-08-14T09:57:09.002Z	INFO	handlers/utils.go:46	getting operation status	{"id": "0db2abc6-89c8-4c4e-82ac-072fe456eb57", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerPendingOperationInProgress (0.00s)
=== RUN   TestRBOperationHandlerPendingOperationCompletedSuccessfully
2024-08-14T09:57:09.002Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "87b0fd49-79d5-42d2-b565-a2bed039ec9b", "type": "RB", "state": "PENDING", "message": ""}
2024-08-14T09:57:09.002Z	INFO	handlers/utils.go:46	getting operation status	{"id": "87b0fd49-79d5-42d2-b565-a2bed039ec9b", "type": "RB", "ydb_operation_id": "1"}
2024-08-14T09:57:09.002Z	INFO	handlers/restore_backup.go:120	forgetting operation	{"id": "87b0fd49-79d5-42d2-b565-a2bed039ec9b", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerPendingOperationCompletedSuccessfully (0.00s)
=== RUN   TestRBOperationHandlerPendingOperationCancelled
2024-08-14T09:57:09.002Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "ef38ca09-0c69-42ea-925e-db630ab7c92e", "type": "RB", "state": "PENDING", "message": ""}
2024-08-14T09:57:09.002Z	INFO	handlers/utils.go:46	getting operation status	{"id": "ef38ca09-0c69-42ea-925e-db630ab7c92e", "type": "RB", "ydb_operation_id": "1"}
2024-08-14T09:57:09.002Z	INFO	handlers/restore_backup.go:120	forgetting operation	{"id": "ef38ca09-0c69-42ea-925e-db630ab7c92e", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerPendingOperationCancelled (0.00s)
=== RUN   TestRBOperationHandlerDeadlineExceededForCancellingOperation
2024-08-14T09:57:09.003Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "08faa27b-17eb-4763-8912-229b2948829b", "type": "RB", "state": "CANCELLING", "message": ""}
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "08faa27b-17eb-4763-8912-229b2948829b", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerDeadlineExceededForCancellingOperation (0.00s)
=== RUN   TestRBOperationHandlerCancellingOperationInProgress
2024-08-14T09:57:09.003Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "fcfdaeb8-5b18-430c-ac60-c4470dc36778", "type": "RB", "state": "CANCELLING", "message": ""}
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "fcfdaeb8-5b18-430c-ac60-c4470dc36778", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerCancellingOperationInProgress (0.00s)
=== RUN   TestRBOperationHandlerCancellingOperationCompletedSuccessfully
2024-08-14T09:57:09.003Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "2c5f168a-cc3f-49d2-a957-feb670deb290", "type": "RB", "state": "CANCELLING", "message": ""}
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "2c5f168a-cc3f-49d2-a957-feb670deb290", "type": "RB", "ydb_operation_id": "1"}
2024-08-14T09:57:09.003Z	INFO	handlers/restore_backup.go:120	forgetting operation	{"id": "2c5f168a-cc3f-49d2-a957-feb670deb290", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerCancellingOperationCompletedSuccessfully (0.00s)
=== RUN   TestRBOperationHandlerCancellingOperationCancelled
2024-08-14T09:57:09.003Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "5827acf1-3915-4c12-bf41-1c3c21754bb0", "type": "RB", "state": "CANCELLING", "message": ""}
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "5827acf1-3915-4c12-bf41-1c3c21754bb0", "type": "RB", "ydb_operation_id": "1"}
2024-08-14T09:57:09.003Z	INFO	handlers/restore_backup.go:120	forgetting operation	{"id": "5827acf1-3915-4c12-bf41-1c3c21754bb0", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerCancellingOperationCancelled (0.00s)
=== RUN   TestRBOperationHandlerRetriableErrorForPendingOperation
2024-08-14T09:57:09.003Z	INFO	handlers/restore_backup.go:31	received operation	{"id": "424e4406-f798-4098-b8e6-ac2f582beefc", "type": "RB", "state": "PENDING", "message": ""}
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "424e4406-f798-4098-b8e6-ac2f582beefc", "type": "RB", "ydb_operation_id": "1"}
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:69	received retriable error	{"id": "424e4406-f798-4098-b8e6-ac2f582beefc", "type": "RB", "ydb_operation_id": "1"}
--- PASS: TestRBOperationHandlerRetriableErrorForPendingOperation (0.00s)
=== RUN   TestTBOperationHandlerInvalidOperationResponse
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "6d497f85-0ad7-42bc-a47a-493dda5b4571", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerInvalidOperationResponse (0.00s)
=== RUN   TestTBOperationHandlerDeadlineExceededForPendingOperation
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "358a6108-72e6-456b-b72b-6146b4b1bb2e", "type": "TB", "ydb_operation_id": "1"}
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:99	cancelling operation	{"reason": "TTL", "id": "358a6108-72e6-456b-b72b-6146b4b1bb2e", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerDeadlineExceededForPendingOperation (0.00s)
=== RUN   TestTBOperationHandlerPendingOperationInProgress
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "87804333-26cb-41f7-adf9-bfc93d51b60a", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerPendingOperationInProgress (0.00s)
=== RUN   TestTBOperationHandlerPendingOperationCompletedSuccessfully
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "4d2bd416-943e-4e04-b971-d607d125ab4f", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerPendingOperationCompletedSuccessfully (0.00s)
=== RUN   TestTBOperationHandlerPendingOperationCancelled
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "e7ac068b-34c9-4344-8932-784c9552d93c", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerPendingOperationCancelled (0.00s)
=== RUN   TestTBOperationHandlerDeadlineExceededForCancellingOperation
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "9e840edb-de3f-49f7-8ee3-f26c05dbdb10", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerDeadlineExceededForCancellingOperation (0.00s)
=== RUN   TestTBOperationHandlerCancellingOperationInProgress
2024-08-14T09:57:09.003Z	INFO	handlers/utils.go:46	getting operation status	{"id": "d69e69a6-57ba-4e12-abac-2a6c4aaadaac", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerCancellingOperationInProgress (0.00s)
=== RUN   TestTBOperationHandlerCancellingOperationCompletedSuccessfully
2024-08-14T09:57:09.004Z	INFO	handlers/utils.go:46	getting operation status	{"id": "2adcd1e0-28cb-4e2c-99e5-8d1cbd472960", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerCancellingOperationCompletedSuccessfully (0.00s)
=== RUN   TestTBOperationHandlerCancellingOperationCancelled
2024-08-14T09:57:09.004Z	INFO	handlers/utils.go:46	getting operation status	{"id": "191fe542-b257-47d2-a3b9-e3d2c3b310bf", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerCancellingOperationCancelled (0.00s)
=== RUN   TestTBOperationHandlerRetriableErrorForPendingOperation
2024-08-14T09:57:09.004Z	INFO	handlers/utils.go:46	getting operation status	{"id": "b808e559-50e3-41c3-80cc-5385d78bb960", "type": "TB", "ydb_operation_id": "1"}
2024-08-14T09:57:09.004Z	INFO	handlers/utils.go:69	received retriable error	{"id": "b808e559-50e3-41c3-80cc-5385d78bb960", "type": "TB", "ydb_operation_id": "1"}
--- PASS: TestTBOperationHandlerRetriableErrorForPendingOperation (0.00s)
🟢 ydbcp/internal/processor2009ms
🧪 Tests
  • 🟢TestOperationHandlerRegistry
  • 🟢TestProcessor
🖨️ Output
=== RUN   TestProcessor
2024-08-14T09:57:09.003Z	DEBUG	processor/processor.go:76	Operation Processor started	{"period": "10s"}
2024-08-14T09:57:09.003Z	DEBUG	processor/processor.go:108	operation already running	{"operation": "Operation, id 6cb33fd2-3140-44de-b0d5-3b0170bdd590, type TB, state PENDING"}
2024-08-14T09:57:09.003Z	DEBUG	processor/processor.go:108	operation already running	{"operation": "Operation, id 6cb33fd2-3140-44de-b0d5-3b0170bdd590, type TB, state PENDING"}
2024-08-14T09:57:09.003Z	DEBUG	processor/processor.go:120	start operation handler	{"operation": "Operation, id 6cb33fd2-3140-44de-b0d5-3b0170bdd590, type TB, state PENDING"}
2024-08-14T09:57:09.003Z	DEBUG	processor/processor_test.go:41	TB handler called for operation	{"operation": "Operation, id 6cb33fd2-3140-44de-b0d5-3b0170bdd590, type TB, state PENDING"}
2024-08-14T09:57:09.003Z	DEBUG	processor/processor.go:137	operation handler is finished	{"operationID": "6cb33fd2-3140-44de-b0d5-3b0170bdd590"}
2024-08-14T09:57:09.003Z	DEBUG	processor/processor.go:83	Operation Processor stopped
--- PASS: TestProcessor (0.00s)
=== RUN   TestOperationHandlerRegistry
--- PASS: TestOperationHandlerRegistry (0.00s)
🟡 ydbcp/internal/types0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/util/ticker0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/util/timer0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/internal/util/xlog0000ms
🧪 Tests(none)
🖨️ Output
(none)
🟡 ydbcp/pkg/proto/ydbcp/v1alpha10000ms
🧪 Tests(none)
🖨️ Output
(none)

@qrort qrort merged commit 3130b38 into main Aug 15, 2024
1 check passed
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.

3 participants