diff --git a/core/src/io/anuke/mindustry/world/blocks/liquid/LiquidBridge.java b/core/src/io/anuke/mindustry/world/blocks/liquid/LiquidBridge.java
index 5373acdc6f..f64a16ba80 100644
--- a/core/src/io/anuke/mindustry/world/blocks/liquid/LiquidBridge.java
+++ b/core/src/io/anuke/mindustry/world/blocks/liquid/LiquidBridge.java
@@ -30,6 +30,8 @@ public class LiquidBridge extends ItemBridge{
         if(!linkValid(tile, other)){
             tryDumpLiquid(tile, entity.liquids.current());
         }else{
+            ((ItemBridgeEntity)world.tile(entity.link).entity).incoming.add(tile.pos());
+
             if(entity.cons.valid()){
                 float alpha = 0.04f;
                 if(hasPower){
diff --git a/core/src/io/anuke/mindustry/world/blocks/liquid/LiquidExtendingBridge.java b/core/src/io/anuke/mindustry/world/blocks/liquid/LiquidExtendingBridge.java
index be0edc1bff..8c82053b7f 100644
--- a/core/src/io/anuke/mindustry/world/blocks/liquid/LiquidExtendingBridge.java
+++ b/core/src/io/anuke/mindustry/world/blocks/liquid/LiquidExtendingBridge.java
@@ -30,6 +30,8 @@ public class LiquidExtendingBridge extends ExtendingItemBridge{
         if(!linkValid(tile, other)){
             tryDumpLiquid(tile, entity.liquids.current());
         }else{
+            ((ItemBridgeEntity)world.tile(entity.link).entity).incoming.add(tile.pos());
+
             if(entity.cons.valid()){
                 entity.uptime = Mathf.lerpDelta(entity.uptime, 1f, 0.04f);
             }else{