@@ -435,20 +435,6 @@ static inline void reset_apply_error_context_info(void);
435
435
static TransApplyAction get_transaction_apply_action (TransactionId xid ,
436
436
ParallelApplyWorkerInfo * * winfo );
437
437
438
- /*
439
- * Return the name of the logical replication worker.
440
- */
441
- static const char *
442
- get_worker_name (void )
443
- {
444
- if (am_tablesync_worker ())
445
- return _ ("logical replication table synchronization worker" );
446
- else if (am_parallel_apply_worker ())
447
- return _ ("logical replication parallel apply worker" );
448
- else
449
- return _ ("logical replication apply worker" );
450
- }
451
-
452
438
/*
453
439
* Form the origin name for the subscription.
454
440
*
@@ -3904,9 +3890,8 @@ maybe_reread_subscription(void)
3904
3890
if (!newsub )
3905
3891
{
3906
3892
ereport (LOG ,
3907
- /* translator: first %s is the name of logical replication worker */
3908
- (errmsg ("%s for subscription \"%s\" will stop because the subscription was removed" ,
3909
- get_worker_name (), MySubscription -> name )));
3893
+ (errmsg ("logical replication worker for subscription \"%s\" will stop because the subscription was removed" ,
3894
+ MySubscription -> name )));
3910
3895
3911
3896
/* Ensure we remove no-longer-useful entry for worker's start time */
3912
3897
if (!am_tablesync_worker () && !am_parallel_apply_worker ())
@@ -3918,9 +3903,8 @@ maybe_reread_subscription(void)
3918
3903
if (!newsub -> enabled )
3919
3904
{
3920
3905
ereport (LOG ,
3921
- /* translator: first %s is the name of logical replication worker */
3922
- (errmsg ("%s for subscription \"%s\" will stop because the subscription was disabled" ,
3923
- get_worker_name (), MySubscription -> name )));
3906
+ (errmsg ("logical replication worker for subscription \"%s\" will stop because the subscription was disabled" ,
3907
+ MySubscription -> name )));
3924
3908
3925
3909
apply_worker_exit ();
3926
3910
}
@@ -3954,9 +3938,8 @@ maybe_reread_subscription(void)
3954
3938
MySubscription -> name )));
3955
3939
else
3956
3940
ereport (LOG ,
3957
- /* translator: first %s is the name of logical replication worker */
3958
- (errmsg ("%s for subscription \"%s\" will restart because of a parameter change" ,
3959
- get_worker_name (), MySubscription -> name )));
3941
+ (errmsg ("logical replication worker for subscription \"%s\" will restart because of a parameter change" ,
3942
+ MySubscription -> name )));
3960
3943
3961
3944
apply_worker_exit ();
3962
3945
}
@@ -4478,9 +4461,8 @@ InitializeApplyWorker(void)
4478
4461
if (!MySubscription )
4479
4462
{
4480
4463
ereport (LOG ,
4481
- /* translator: %s is the name of logical replication worker */
4482
- (errmsg ("%s for subscription %u will not start because the subscription was removed during startup" ,
4483
- get_worker_name (), MyLogicalRepWorker -> subid )));
4464
+ (errmsg ("logical replication worker for subscription %u will not start because the subscription was removed during startup" ,
4465
+ MyLogicalRepWorker -> subid )));
4484
4466
4485
4467
/* Ensure we remove no-longer-useful entry for worker's start time */
4486
4468
if (!am_tablesync_worker () && !am_parallel_apply_worker ())
@@ -4494,9 +4476,8 @@ InitializeApplyWorker(void)
4494
4476
if (!MySubscription -> enabled )
4495
4477
{
4496
4478
ereport (LOG ,
4497
- /* translator: first %s is the name of logical replication worker */
4498
- (errmsg ("%s for subscription \"%s\" will not start because the subscription was disabled during startup" ,
4499
- get_worker_name (), MySubscription -> name )));
4479
+ (errmsg ("logical replication worker for subscription \"%s\" will not start because the subscription was disabled during startup" ,
4480
+ MySubscription -> name )));
4500
4481
4501
4482
apply_worker_exit ();
4502
4483
}
@@ -4517,9 +4498,8 @@ InitializeApplyWorker(void)
4517
4498
get_rel_name (MyLogicalRepWorker -> relid ))));
4518
4499
else
4519
4500
ereport (LOG ,
4520
- /* translator: first %s is the name of logical replication worker */
4521
- (errmsg ("%s for subscription \"%s\" has started" ,
4522
- get_worker_name (), MySubscription -> name )));
4501
+ (errmsg ("logical replication apply worker for subscription \"%s\" has started" ,
4502
+ MySubscription -> name )));
4523
4503
4524
4504
CommitTransactionCommand ();
4525
4505
}
0 commit comments